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

Status: SUCCEEDED
Submitted: 2026/07/22 02:21:53
Duration: 0.2 s
Associated SQL Query: 41303
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 2
Skipped Stages: 117

Event Timeline

Enable zooming

No DAG visualization information to display for job 56525

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1573671	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49 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 02:21:53	7 ms	1/1
1573670	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49 start at FileStorageAdapterImpl.java:598 +details RDD: MapPartitionsRDD (3) Project [shardId#6605741, worklistShardItemId#6605819L, version#6605828, product#6605889, plant#6605884, availabilityDateTime#6605891 AS periodStart#6605928, nextAvailabilityDateTime#6605892 AS periodEnd#6605929, qty#6605824] +- (3) BroadcastHashJoin [worklistShardItemId#6605819L], [worklistShardItemId#6605903L], LeftOuter, BuildRight, (shardId#6605741 = 0_1_10000002290), false :- (3) Project [shardId#6605741, worklistShardItemId#6605819L, qty#6605824, element_at([14], ((cast(array_position([0_1_10000002290], shardId#6605741) as int) - 1) + 1), None, false) AS version#6605828] : +- (3) Generate explode(requestedQuantities#6605822), [shardId#6605741, worklistShardItemId#6605819L], false, [qty#6605824] : +- (3) Project [shardId#6605741, item#6605818.worklistShardItemId AS worklistShardItemId#6605819L, item#6605818.requestedQuantities AS requestedQuantities#6605822] : +- (3) Filter ((size(item#6605818.requestedQuantities, true) > 0) AND isnotnull(item#6605818.requestedQuantit... 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 02:21:53	0.2 s	30/30	932.0 B			62.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1573671

tenants-pool-679

stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49 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 02:21:53

7 ms

1/1

1573670

tenants-pool-679

stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49 start at FileStorageAdapterImpl.java:598 +details

RDD: MapPartitionsRDD *(3) Project [shardId#6605741, worklistShardItemId#6605819L, version#6605828, product#6605889, plant#6605884, availabilityDateTime#6605891 AS periodStart#6605928, nextAvailabilityDateTime#6605892 AS periodEnd#6605929, qty#6605824] +- *(3) BroadcastHashJoin [worklistShardItemId#6605819L], [worklistShardItemId#6605903L], LeftOuter, BuildRight, (shardId#6605741 = 0_1_10000002290), false :- *(3) Project [shardId#6605741, worklistShardItemId#6605819L, qty#6605824, element_at([14], ((cast(array_position([0_1_10000002290], shardId#6605741) as int) - 1) + 1), None, false) AS version#6605828] : +- *(3) Generate explode(requestedQuantities#6605822), [shardId#6605741, worklistShardItemId#6605819L], false, [qty#6605824] : +- *(3) Project [shardId#6605741, item#6605818.worklistShardItemId AS worklistShardItemId#6605819L, item#6605818.requestedQuantities AS requestedQuantities#6605822] : +- *(3) Filter ((size(item#6605818.requestedQuantities, true) > 0) AND isnotnull(item#6605818.requestedQuantit...

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 02:21:53

0.2 s

30/30

932.0 B

62.0 B

Page:

Skipped Stages (117)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1573669	Unknown +details Unknown	Unknown	Unknown	0/0
1573668	Unknown +details Unknown	Unknown	Unknown	0/0
1573667	Unknown +details Unknown	Unknown	Unknown	0/0
1573666	Unknown +details Unknown	Unknown	Unknown	0/0
1573665	Unknown +details Unknown	Unknown	Unknown	0/0
1573664	Unknown +details Unknown	Unknown	Unknown	0/0
1573663	Unknown +details Unknown	Unknown	Unknown	0/0
1573662	Unknown +details Unknown	Unknown	Unknown	0/0
1573661	Unknown +details Unknown	Unknown	Unknown	0/0
1573660	Unknown +details Unknown	Unknown	Unknown	0/0
1573659	Unknown +details Unknown	Unknown	Unknown	0/0
1573658	Unknown +details Unknown	Unknown	Unknown	0/0
1573657	Unknown +details Unknown	Unknown	Unknown	0/0
1573656	Unknown +details Unknown	Unknown	Unknown	0/0
1573655	Unknown +details Unknown	Unknown	Unknown	0/0
1573654	Unknown +details Unknown	Unknown	Unknown	0/0
1573653	Unknown +details Unknown	Unknown	Unknown	0/0
1573652	Unknown +details Unknown	Unknown	Unknown	0/0
1573651	Unknown +details Unknown	Unknown	Unknown	0/0
1573650	Unknown +details Unknown	Unknown	Unknown	0/0
1573649	Unknown +details Unknown	Unknown	Unknown	0/0
1573648	Unknown +details Unknown	Unknown	Unknown	0/0
1573647	Unknown +details Unknown	Unknown	Unknown	0/0
1573646	Unknown +details Unknown	Unknown	Unknown	0/0
1573645	Unknown +details Unknown	Unknown	Unknown	0/0
1573644	Unknown +details Unknown	Unknown	Unknown	0/0
1573643	Unknown +details Unknown	Unknown	Unknown	0/0
1573642	Unknown +details Unknown	Unknown	Unknown	0/0
1573641	Unknown +details Unknown	Unknown	Unknown	0/0
1573640	Unknown +details Unknown	Unknown	Unknown	0/0
1573639	Unknown +details Unknown	Unknown	Unknown	0/0
1573638	Unknown +details Unknown	Unknown	Unknown	0/0
1573637	Unknown +details Unknown	Unknown	Unknown	0/0
1573636	Unknown +details Unknown	Unknown	Unknown	0/0
1573635	Unknown +details Unknown	Unknown	Unknown	0/0
1573634	Unknown +details Unknown	Unknown	Unknown	0/0
1573633	Unknown +details Unknown	Unknown	Unknown	0/0
1573632	Unknown +details Unknown	Unknown	Unknown	0/0
1573631	Unknown +details Unknown	Unknown	Unknown	0/0
1573630	Unknown +details Unknown	Unknown	Unknown	0/0
1573629	Unknown +details Unknown	Unknown	Unknown	0/0
1573628	Unknown +details Unknown	Unknown	Unknown	0/0
1573627	Unknown +details Unknown	Unknown	Unknown	0/0
1573626	Unknown +details Unknown	Unknown	Unknown	0/0
1573625	Unknown +details Unknown	Unknown	Unknown	0/0
1573624	Unknown +details Unknown	Unknown	Unknown	0/0
1573623	Unknown +details Unknown	Unknown	Unknown	0/0
1573622	Unknown +details Unknown	Unknown	Unknown	0/0
1573621	Unknown +details Unknown	Unknown	Unknown	0/0
1573620	Unknown +details Unknown	Unknown	Unknown	0/0
1573619	Unknown +details Unknown	Unknown	Unknown	0/0
1573618	Unknown +details Unknown	Unknown	Unknown	0/0
1573617	Unknown +details Unknown	Unknown	Unknown	0/0
1573616	Unknown +details Unknown	Unknown	Unknown	0/0
1573615	Unknown +details Unknown	Unknown	Unknown	0/0
1573614	Unknown +details Unknown	Unknown	Unknown	0/0
1573613	Unknown +details Unknown	Unknown	Unknown	0/0
1573612	Unknown +details Unknown	Unknown	Unknown	0/0
1573611	Unknown +details Unknown	Unknown	Unknown	0/0
1573610	Unknown +details Unknown	Unknown	Unknown	0/0
1573609	Unknown +details Unknown	Unknown	Unknown	0/0
1573608	Unknown +details Unknown	Unknown	Unknown	0/0
1573607	Unknown +details Unknown	Unknown	Unknown	0/0
1573606	Unknown +details Unknown	Unknown	Unknown	0/0
1573605	Unknown +details Unknown	Unknown	Unknown	0/0
1573604	Unknown +details Unknown	Unknown	Unknown	0/0
1573603	Unknown +details Unknown	Unknown	Unknown	0/0
1573602	Unknown +details Unknown	Unknown	Unknown	0/0
1573601	Unknown +details Unknown	Unknown	Unknown	0/0
1573600	Unknown +details Unknown	Unknown	Unknown	0/0
1573599	Unknown +details Unknown	Unknown	Unknown	0/0
1573598	Unknown +details Unknown	Unknown	Unknown	0/0
1573597	Unknown +details Unknown	Unknown	Unknown	0/0
1573596	Unknown +details Unknown	Unknown	Unknown	0/0
1573595	Unknown +details Unknown	Unknown	Unknown	0/0
1573594	Unknown +details Unknown	Unknown	Unknown	0/0
1573593	Unknown +details Unknown	Unknown	Unknown	0/0
1573592	Unknown +details Unknown	Unknown	Unknown	0/0
1573591	Unknown +details Unknown	Unknown	Unknown	0/0
1573590	Unknown +details Unknown	Unknown	Unknown	0/0
1573589	Unknown +details Unknown	Unknown	Unknown	0/0
1573588	Unknown +details Unknown	Unknown	Unknown	0/0
1573587	Unknown +details Unknown	Unknown	Unknown	0/0
1573586	Unknown +details Unknown	Unknown	Unknown	0/0
1573585	Unknown +details Unknown	Unknown	Unknown	0/0
1573584	Unknown +details Unknown	Unknown	Unknown	0/0
1573583	Unknown +details Unknown	Unknown	Unknown	0/0
1573582	Unknown +details Unknown	Unknown	Unknown	0/0
1573581	Unknown +details Unknown	Unknown	Unknown	0/0
1573580	Unknown +details Unknown	Unknown	Unknown	0/0
1573579	Unknown +details Unknown	Unknown	Unknown	0/0
1573578	Unknown +details Unknown	Unknown	Unknown	0/0
1573577	Unknown +details Unknown	Unknown	Unknown	0/0
1573576	Unknown +details Unknown	Unknown	Unknown	0/0
1573575	Unknown +details Unknown	Unknown	Unknown	0/0
1573574	Unknown +details Unknown	Unknown	Unknown	0/0
1573573	Unknown +details Unknown	Unknown	Unknown	0/0
1573572	Unknown +details Unknown	Unknown	Unknown	0/0
1573571	Unknown +details Unknown	Unknown	Unknown	0/0
1573570	Unknown +details Unknown	Unknown	Unknown	0/0

Page: