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

Status: SUCCEEDED
Submitted: 2026/07/22 20:37:01
Duration: 0.3 s
Associated SQL Query: 93781
Job Group: f82340b3-4413-4826-9fdb-37fdaa6940fe
Completed Stages: 2
Skipped Stages: 110

Event Timeline

Enable zooming

No DAG visualization information to display for job 127249

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3726839	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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:37:01	12 ms	1/1
3726838	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 start at FileStorageAdapterImpl.java:598 +details RDD: (1) Filter (isnotnull(shardId#15070782) AND (shardId#15070782 = 0_1_10000001452)) +- (1) Scan ExistingRDD[shardId#15070782,orderProposalId#15070783L,items#15070784,optimizationGroups#15070785,isOptimal#15070786,lastModified#15070787,optimizationInsights#15070788] 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:37:01	0.2 s	30/30	1474.0 B			124.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3726839

tenants-pool-169

stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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:37:01

12 ms

1/1

3726838

tenants-pool-169

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

RDD: *(1) Filter (isnotnull(shardId#15070782) AND (shardId#15070782 = 0_1_10000001452)) +- *(1) Scan ExistingRDD[shardId#15070782,orderProposalId#15070783L,items#15070784,optimizationGroups#15070785,isOptimal#15070786,lastModified#15070787,optimizationInsights#15070788]

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:37:01

0.2 s

30/30

1474.0 B

124.0 B

Page:

Skipped Stages (110)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
3726837	Unknown +details Unknown	Unknown	Unknown	0/0
3726836	Unknown +details Unknown	Unknown	Unknown	0/0
3726835	Unknown +details Unknown	Unknown	Unknown	0/0
3726834	Unknown +details Unknown	Unknown	Unknown	0/0
3726833	Unknown +details Unknown	Unknown	Unknown	0/0
3726832	Unknown +details Unknown	Unknown	Unknown	0/0
3726831	Unknown +details Unknown	Unknown	Unknown	0/0
3726830	Unknown +details Unknown	Unknown	Unknown	0/0
3726829	Unknown +details Unknown	Unknown	Unknown	0/0
3726828	Unknown +details Unknown	Unknown	Unknown	0/0
3726827	Unknown +details Unknown	Unknown	Unknown	0/0
3726826	Unknown +details Unknown	Unknown	Unknown	0/0
3726825	Unknown +details Unknown	Unknown	Unknown	0/0
3726824	Unknown +details Unknown	Unknown	Unknown	0/0
3726823	Unknown +details Unknown	Unknown	Unknown	0/0
3726822	Unknown +details Unknown	Unknown	Unknown	0/0
3726821	Unknown +details Unknown	Unknown	Unknown	0/0
3726820	Unknown +details Unknown	Unknown	Unknown	0/0
3726819	Unknown +details Unknown	Unknown	Unknown	0/0
3726818	Unknown +details Unknown	Unknown	Unknown	0/0
3726817	Unknown +details Unknown	Unknown	Unknown	0/0
3726816	Unknown +details Unknown	Unknown	Unknown	0/0
3726815	Unknown +details Unknown	Unknown	Unknown	0/0
3726814	Unknown +details Unknown	Unknown	Unknown	0/0
3726813	Unknown +details Unknown	Unknown	Unknown	0/0
3726812	Unknown +details Unknown	Unknown	Unknown	0/0
3726811	Unknown +details Unknown	Unknown	Unknown	0/0
3726810	Unknown +details Unknown	Unknown	Unknown	0/0
3726809	Unknown +details Unknown	Unknown	Unknown	0/0
3726808	Unknown +details Unknown	Unknown	Unknown	0/0
3726807	Unknown +details Unknown	Unknown	Unknown	0/0
3726806	Unknown +details Unknown	Unknown	Unknown	0/0
3726805	Unknown +details Unknown	Unknown	Unknown	0/0
3726804	Unknown +details Unknown	Unknown	Unknown	0/0
3726803	Unknown +details Unknown	Unknown	Unknown	0/0
3726802	Unknown +details Unknown	Unknown	Unknown	0/0
3726801	Unknown +details Unknown	Unknown	Unknown	0/0
3726800	Unknown +details Unknown	Unknown	Unknown	0/0
3726799	Unknown +details Unknown	Unknown	Unknown	0/0
3726798	Unknown +details Unknown	Unknown	Unknown	0/0
3726797	Unknown +details Unknown	Unknown	Unknown	0/0
3726796	Unknown +details Unknown	Unknown	Unknown	0/0
3726795	Unknown +details Unknown	Unknown	Unknown	0/0
3726794	Unknown +details Unknown	Unknown	Unknown	0/0
3726793	Unknown +details Unknown	Unknown	Unknown	0/0
3726792	Unknown +details Unknown	Unknown	Unknown	0/0
3726791	Unknown +details Unknown	Unknown	Unknown	0/0
3726790	Unknown +details Unknown	Unknown	Unknown	0/0
3726789	Unknown +details Unknown	Unknown	Unknown	0/0
3726788	Unknown +details Unknown	Unknown	Unknown	0/0
3726787	Unknown +details Unknown	Unknown	Unknown	0/0
3726786	Unknown +details Unknown	Unknown	Unknown	0/0
3726785	Unknown +details Unknown	Unknown	Unknown	0/0
3726784	Unknown +details Unknown	Unknown	Unknown	0/0
3726783	Unknown +details Unknown	Unknown	Unknown	0/0
3726782	Unknown +details Unknown	Unknown	Unknown	0/0
3726781	Unknown +details Unknown	Unknown	Unknown	0/0
3726780	Unknown +details Unknown	Unknown	Unknown	0/0
3726779	Unknown +details Unknown	Unknown	Unknown	0/0
3726778	Unknown +details Unknown	Unknown	Unknown	0/0
3726777	Unknown +details Unknown	Unknown	Unknown	0/0
3726776	Unknown +details Unknown	Unknown	Unknown	0/0
3726775	Unknown +details Unknown	Unknown	Unknown	0/0
3726774	Unknown +details Unknown	Unknown	Unknown	0/0
3726773	Unknown +details Unknown	Unknown	Unknown	0/0
3726772	Unknown +details Unknown	Unknown	Unknown	0/0
3726771	Unknown +details Unknown	Unknown	Unknown	0/0
3726770	Unknown +details Unknown	Unknown	Unknown	0/0
3726769	Unknown +details Unknown	Unknown	Unknown	0/0
3726768	Unknown +details Unknown	Unknown	Unknown	0/0
3726767	Unknown +details Unknown	Unknown	Unknown	0/0
3726766	Unknown +details Unknown	Unknown	Unknown	0/0
3726765	Unknown +details Unknown	Unknown	Unknown	0/0
3726764	Unknown +details Unknown	Unknown	Unknown	0/0
3726763	Unknown +details Unknown	Unknown	Unknown	0/0
3726762	Unknown +details Unknown	Unknown	Unknown	0/0
3726761	Unknown +details Unknown	Unknown	Unknown	0/0
3726760	Unknown +details Unknown	Unknown	Unknown	0/0
3726759	Unknown +details Unknown	Unknown	Unknown	0/0
3726758	Unknown +details Unknown	Unknown	Unknown	0/0
3726757	Unknown +details Unknown	Unknown	Unknown	0/0
3726756	Unknown +details Unknown	Unknown	Unknown	0/0
3726755	Unknown +details Unknown	Unknown	Unknown	0/0
3726754	Unknown +details Unknown	Unknown	Unknown	0/0
3726753	Unknown +details Unknown	Unknown	Unknown	0/0
3726752	Unknown +details Unknown	Unknown	Unknown	0/0
3726751	Unknown +details Unknown	Unknown	Unknown	0/0
3726750	Unknown +details Unknown	Unknown	Unknown	0/0
3726749	Unknown +details Unknown	Unknown	Unknown	0/0
3726748	Unknown +details Unknown	Unknown	Unknown	0/0
3726747	Unknown +details Unknown	Unknown	Unknown	0/0
3726746	Unknown +details Unknown	Unknown	Unknown	0/0
3726745	Unknown +details Unknown	Unknown	Unknown	0/0
3726744	Unknown +details Unknown	Unknown	Unknown	0/0
3726743	Unknown +details Unknown	Unknown	Unknown	0/0
3726742	Unknown +details Unknown	Unknown	Unknown	0/0
3726741	Unknown +details Unknown	Unknown	Unknown	0/0
3726740	Unknown +details Unknown	Unknown	Unknown	0/0
3726739	Unknown +details Unknown	Unknown	Unknown	0/0
3726738	Unknown +details Unknown	Unknown	Unknown	0/0

Page: