crp-order-qty-opt-service - Details for Job 127225

Status: SUCCEEDED
Submitted: 2026/07/22 20:36:42
Duration: 0.2 s
Associated SQL Query: 93761
Job Group: f82340b3-4413-4826-9fdb-37fdaa6940fe
Completed Stages: 2
Skipped Stages: 95

Event Timeline

Enable zooming

No DAG visualization information to display for job 127225

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3725701	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 68 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/07/22 20:36:42	6 ms	1/1
3725700	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 68 start at FileStorageAdapterImpl.java:598 +details RDD: MapPartitionsRDD (3) Project [shardId#15068308, worklistShardItemId#15068386L, version#15068395, product#15068456, plant#15068451, availabilityDateTime#15068458 AS periodStart#15068495, nextAvailabilityDateTime#15068459 AS periodEnd#15068496, qty#15068391] +- (3) BroadcastHashJoin [worklistShardItemId#15068386L], [worklistShardItemId#15068470L], LeftOuter, BuildRight, (shardId#15068308 = 0_1_10000001452), false :- (3) Project [shardId#15068308, worklistShardItemId#15068386L, qty#15068391, element_at([12], ((cast(array_position([0_1_10000001452], shardId#15068308) as int) - 1) + 1), None, false) AS version#15068395] : +- (3) Generate explode(requestedQuantities#15068389), [shardId#15068308, worklistShardItemId#15068386L], false, [qty#15068391] : +- (3) Project [shardId#15068308, item#15068385.worklistShardItemId AS worklistShardItemId#15068386L, item#15068385.requestedQuantities AS requestedQuantities#15068389] : +- (3) Filter ((size(item#15068385.requestedQuantities, true) > 0) AND isnotnull(i... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/07/22 20:36:42	0.2 s	30/30	1004.0 B			62.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3725701

tenants-pool-169

stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 68 start at FileStorageAdapterImpl.java:598 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/07/22 20:36:42

6 ms

1/1

3725700

tenants-pool-169

stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 68 start at FileStorageAdapterImpl.java:598 +details

RDD: MapPartitionsRDD *(3) Project [shardId#15068308, worklistShardItemId#15068386L, version#15068395, product#15068456, plant#15068451, availabilityDateTime#15068458 AS periodStart#15068495, nextAvailabilityDateTime#15068459 AS periodEnd#15068496, qty#15068391] +- *(3) BroadcastHashJoin [worklistShardItemId#15068386L], [worklistShardItemId#15068470L], LeftOuter, BuildRight, (shardId#15068308 = 0_1_10000001452), false :- *(3) Project [shardId#15068308, worklistShardItemId#15068386L, qty#15068391, element_at([12], ((cast(array_position([0_1_10000001452], shardId#15068308) as int) - 1) + 1), None, false) AS version#15068395] : +- *(3) Generate explode(requestedQuantities#15068389), [shardId#15068308, worklistShardItemId#15068386L], false, [qty#15068391] : +- *(3) Project [shardId#15068308, item#15068385.worklistShardItemId AS worklistShardItemId#15068386L, item#15068385.requestedQuantities AS requestedQuantities#15068389] : +- *(3) Filter ((size(item#15068385.requestedQuantities, true) > 0) AND isnotnull(i...

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/07/22 20:36:42

0.2 s

30/30

1004.0 B

62.0 B

Page:

Skipped Stages (95)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
3725699	Unknown +details Unknown	Unknown	Unknown	0/0
3725698	Unknown +details Unknown	Unknown	Unknown	0/0
3725697	Unknown +details Unknown	Unknown	Unknown	0/0
3725696	Unknown +details Unknown	Unknown	Unknown	0/0
3725695	Unknown +details Unknown	Unknown	Unknown	0/0
3725694	Unknown +details Unknown	Unknown	Unknown	0/0
3725693	Unknown +details Unknown	Unknown	Unknown	0/0
3725692	Unknown +details Unknown	Unknown	Unknown	0/0
3725691	Unknown +details Unknown	Unknown	Unknown	0/0
3725690	Unknown +details Unknown	Unknown	Unknown	0/0
3725689	Unknown +details Unknown	Unknown	Unknown	0/0
3725688	Unknown +details Unknown	Unknown	Unknown	0/0
3725687	Unknown +details Unknown	Unknown	Unknown	0/0
3725686	Unknown +details Unknown	Unknown	Unknown	0/0
3725685	Unknown +details Unknown	Unknown	Unknown	0/0
3725684	Unknown +details Unknown	Unknown	Unknown	0/0
3725683	Unknown +details Unknown	Unknown	Unknown	0/0
3725682	Unknown +details Unknown	Unknown	Unknown	0/0
3725681	Unknown +details Unknown	Unknown	Unknown	0/0
3725680	Unknown +details Unknown	Unknown	Unknown	0/0
3725679	Unknown +details Unknown	Unknown	Unknown	0/0
3725678	Unknown +details Unknown	Unknown	Unknown	0/0
3725677	Unknown +details Unknown	Unknown	Unknown	0/0
3725676	Unknown +details Unknown	Unknown	Unknown	0/0
3725675	Unknown +details Unknown	Unknown	Unknown	0/0
3725674	Unknown +details Unknown	Unknown	Unknown	0/0
3725673	Unknown +details Unknown	Unknown	Unknown	0/0
3725672	Unknown +details Unknown	Unknown	Unknown	0/0
3725671	Unknown +details Unknown	Unknown	Unknown	0/0
3725670	Unknown +details Unknown	Unknown	Unknown	0/0
3725669	Unknown +details Unknown	Unknown	Unknown	0/0
3725668	Unknown +details Unknown	Unknown	Unknown	0/0
3725667	Unknown +details Unknown	Unknown	Unknown	0/0
3725666	Unknown +details Unknown	Unknown	Unknown	0/0
3725665	Unknown +details Unknown	Unknown	Unknown	0/0
3725664	Unknown +details Unknown	Unknown	Unknown	0/0
3725663	Unknown +details Unknown	Unknown	Unknown	0/0
3725662	Unknown +details Unknown	Unknown	Unknown	0/0
3725661	Unknown +details Unknown	Unknown	Unknown	0/0
3725660	Unknown +details Unknown	Unknown	Unknown	0/0
3725659	Unknown +details Unknown	Unknown	Unknown	0/0
3725658	Unknown +details Unknown	Unknown	Unknown	0/0
3725657	Unknown +details Unknown	Unknown	Unknown	0/0
3725656	Unknown +details Unknown	Unknown	Unknown	0/0
3725655	Unknown +details Unknown	Unknown	Unknown	0/0
3725654	Unknown +details Unknown	Unknown	Unknown	0/0
3725653	Unknown +details Unknown	Unknown	Unknown	0/0
3725652	Unknown +details Unknown	Unknown	Unknown	0/0
3725651	Unknown +details Unknown	Unknown	Unknown	0/0
3725650	Unknown +details Unknown	Unknown	Unknown	0/0
3725649	Unknown +details Unknown	Unknown	Unknown	0/0
3725648	Unknown +details Unknown	Unknown	Unknown	0/0
3725647	Unknown +details Unknown	Unknown	Unknown	0/0
3725646	Unknown +details Unknown	Unknown	Unknown	0/0
3725645	Unknown +details Unknown	Unknown	Unknown	0/0
3725644	Unknown +details Unknown	Unknown	Unknown	0/0
3725643	Unknown +details Unknown	Unknown	Unknown	0/0
3725642	Unknown +details Unknown	Unknown	Unknown	0/0
3725641	Unknown +details Unknown	Unknown	Unknown	0/0
3725640	Unknown +details Unknown	Unknown	Unknown	0/0
3725639	Unknown +details Unknown	Unknown	Unknown	0/0
3725638	Unknown +details Unknown	Unknown	Unknown	0/0
3725637	Unknown +details Unknown	Unknown	Unknown	0/0
3725636	Unknown +details Unknown	Unknown	Unknown	0/0
3725635	Unknown +details Unknown	Unknown	Unknown	0/0
3725634	Unknown +details Unknown	Unknown	Unknown	0/0
3725633	Unknown +details Unknown	Unknown	Unknown	0/0
3725632	Unknown +details Unknown	Unknown	Unknown	0/0
3725631	Unknown +details Unknown	Unknown	Unknown	0/0
3725630	Unknown +details Unknown	Unknown	Unknown	0/0
3725629	Unknown +details Unknown	Unknown	Unknown	0/0
3725628	Unknown +details Unknown	Unknown	Unknown	0/0
3725627	Unknown +details Unknown	Unknown	Unknown	0/0
3725626	Unknown +details Unknown	Unknown	Unknown	0/0
3725625	Unknown +details Unknown	Unknown	Unknown	0/0
3725624	Unknown +details Unknown	Unknown	Unknown	0/0
3725623	Unknown +details Unknown	Unknown	Unknown	0/0
3725622	Unknown +details Unknown	Unknown	Unknown	0/0
3725621	Unknown +details Unknown	Unknown	Unknown	0/0
3725620	Unknown +details Unknown	Unknown	Unknown	0/0
3725619	Unknown +details Unknown	Unknown	Unknown	0/0
3725618	Unknown +details Unknown	Unknown	Unknown	0/0
3725617	Unknown +details Unknown	Unknown	Unknown	0/0
3725616	Unknown +details Unknown	Unknown	Unknown	0/0
3725615	Unknown +details Unknown	Unknown	Unknown	0/0
3725614	Unknown +details Unknown	Unknown	Unknown	0/0
3725613	Unknown +details Unknown	Unknown	Unknown	0/0
3725612	Unknown +details Unknown	Unknown	Unknown	0/0
3725611	Unknown +details Unknown	Unknown	Unknown	0/0
3725610	Unknown +details Unknown	Unknown	Unknown	0/0
3725609	Unknown +details Unknown	Unknown	Unknown	0/0
3725608	Unknown +details Unknown	Unknown	Unknown	0/0
3725607	Unknown +details Unknown	Unknown	Unknown	0/0
3725606	Unknown +details Unknown	Unknown	Unknown	0/0
3725605	Unknown +details Unknown	Unknown	Unknown	0/0

Page: