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

Status: SUCCEEDED
Submitted: 2026/09/03 11:18:06
Duration: 2 s
Associated SQL Query: 82760
Job Group: 4bf75fd4-c2e3-496e-bc8a-c063a62efe60
Completed Stages: 3
Skipped Stages: 101

Event Timeline

Enable zooming

No DAG visualization information to display for job 114658

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
2135186	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/03 11:18:06	1 s	30/30		2014.5 KiB	3.4 MiB
2135185	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/03 11:18:06	0.4 s	37/37				3.0 MiB
2135184	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details RDD: (1) Filter (isnotnull(shardId#22197470) AND (shardId#22197470 = 0_7_10000000553)) +- (1) Scan ExistingRDD[shardId#22197470,orderProposalId#22197471L,items#22197472,optimizationGroups#22197473,isOptimal#22197474,lastModified#22197475,optimizationInsights#22197476] org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/03 11:18:06	0.2 s	30/30	296.7 KiB			395.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

2135186

tenants-pool-506

stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/09/03 11:18:06

1 s

30/30

2014.5 KiB

3.4 MiB

2135185

tenants-pool-506

stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/09/03 11:18:06

0.4 s

37/37

3.0 MiB

2135184

tenants-pool-506

stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 start at FileStorageAdapterImpl.java:596 +details

RDD: *(1) Filter (isnotnull(shardId#22197470) AND (shardId#22197470 = 0_7_10000000553)) +- *(1) Scan ExistingRDD[shardId#22197470,orderProposalId#22197471L,items#22197472,optimizationGroups#22197473,isOptimal#22197474,lastModified#22197475,optimizationInsights#22197476]

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/09/03 11:18:06

0.2 s

30/30

296.7 KiB

395.5 KiB

Page:

Skipped Stages (101)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
2135183	Unknown +details Unknown	Unknown	Unknown	0/0
2135182	Unknown +details Unknown	Unknown	Unknown	0/0
2135181	Unknown +details Unknown	Unknown	Unknown	0/0
2135180	Unknown +details Unknown	Unknown	Unknown	0/0
2135179	Unknown +details Unknown	Unknown	Unknown	0/0
2135178	Unknown +details Unknown	Unknown	Unknown	0/0
2135177	Unknown +details Unknown	Unknown	Unknown	0/0
2135176	Unknown +details Unknown	Unknown	Unknown	0/0
2135175	Unknown +details Unknown	Unknown	Unknown	0/0
2135174	Unknown +details Unknown	Unknown	Unknown	0/0
2135173	Unknown +details Unknown	Unknown	Unknown	0/0
2135172	Unknown +details Unknown	Unknown	Unknown	0/0
2135171	Unknown +details Unknown	Unknown	Unknown	0/0
2135170	Unknown +details Unknown	Unknown	Unknown	0/0
2135169	Unknown +details Unknown	Unknown	Unknown	0/0
2135168	Unknown +details Unknown	Unknown	Unknown	0/0
2135167	Unknown +details Unknown	Unknown	Unknown	0/0
2135166	Unknown +details Unknown	Unknown	Unknown	0/0
2135165	Unknown +details Unknown	Unknown	Unknown	0/0
2135164	Unknown +details Unknown	Unknown	Unknown	0/0
2135163	Unknown +details Unknown	Unknown	Unknown	0/0
2135162	Unknown +details Unknown	Unknown	Unknown	0/0
2135161	Unknown +details Unknown	Unknown	Unknown	0/0
2135160	Unknown +details Unknown	Unknown	Unknown	0/0
2135159	Unknown +details Unknown	Unknown	Unknown	0/0
2135158	Unknown +details Unknown	Unknown	Unknown	0/0
2135157	Unknown +details Unknown	Unknown	Unknown	0/0
2135156	Unknown +details Unknown	Unknown	Unknown	0/0
2135155	Unknown +details Unknown	Unknown	Unknown	0/0
2135154	Unknown +details Unknown	Unknown	Unknown	0/0
2135153	Unknown +details Unknown	Unknown	Unknown	0/0
2135152	Unknown +details Unknown	Unknown	Unknown	0/0
2135151	Unknown +details Unknown	Unknown	Unknown	0/0
2135150	Unknown +details Unknown	Unknown	Unknown	0/0
2135149	Unknown +details Unknown	Unknown	Unknown	0/0
2135148	Unknown +details Unknown	Unknown	Unknown	0/0
2135147	Unknown +details Unknown	Unknown	Unknown	0/0
2135146	Unknown +details Unknown	Unknown	Unknown	0/0
2135145	Unknown +details Unknown	Unknown	Unknown	0/0
2135144	Unknown +details Unknown	Unknown	Unknown	0/0
2135143	Unknown +details Unknown	Unknown	Unknown	0/0
2135142	Unknown +details Unknown	Unknown	Unknown	0/0
2135141	Unknown +details Unknown	Unknown	Unknown	0/0
2135140	Unknown +details Unknown	Unknown	Unknown	0/0
2135139	Unknown +details Unknown	Unknown	Unknown	0/0
2135138	Unknown +details Unknown	Unknown	Unknown	0/0
2135137	Unknown +details Unknown	Unknown	Unknown	0/0
2135136	Unknown +details Unknown	Unknown	Unknown	0/0
2135135	Unknown +details Unknown	Unknown	Unknown	0/0
2135134	Unknown +details Unknown	Unknown	Unknown	0/0
2135133	Unknown +details Unknown	Unknown	Unknown	0/0
2135132	Unknown +details Unknown	Unknown	Unknown	0/0
2135131	Unknown +details Unknown	Unknown	Unknown	0/0
2135130	Unknown +details Unknown	Unknown	Unknown	0/0
2135129	Unknown +details Unknown	Unknown	Unknown	0/0
2135128	Unknown +details Unknown	Unknown	Unknown	0/0
2135127	Unknown +details Unknown	Unknown	Unknown	0/0
2135126	Unknown +details Unknown	Unknown	Unknown	0/0
2135125	Unknown +details Unknown	Unknown	Unknown	0/0
2135124	Unknown +details Unknown	Unknown	Unknown	0/0
2135123	Unknown +details Unknown	Unknown	Unknown	0/0
2135122	Unknown +details Unknown	Unknown	Unknown	0/0
2135121	Unknown +details Unknown	Unknown	Unknown	0/0
2135120	Unknown +details Unknown	Unknown	Unknown	0/0
2135119	Unknown +details Unknown	Unknown	Unknown	0/0
2135118	Unknown +details Unknown	Unknown	Unknown	0/0
2135117	Unknown +details Unknown	Unknown	Unknown	0/0
2135116	Unknown +details Unknown	Unknown	Unknown	0/0
2135115	Unknown +details Unknown	Unknown	Unknown	0/0
2135114	Unknown +details Unknown	Unknown	Unknown	0/0
2135113	Unknown +details Unknown	Unknown	Unknown	0/0
2135112	Unknown +details Unknown	Unknown	Unknown	0/0
2135111	Unknown +details Unknown	Unknown	Unknown	0/0
2135110	Unknown +details Unknown	Unknown	Unknown	0/0
2135109	Unknown +details Unknown	Unknown	Unknown	0/0
2135108	Unknown +details Unknown	Unknown	Unknown	0/0
2135107	Unknown +details Unknown	Unknown	Unknown	0/0
2135106	Unknown +details Unknown	Unknown	Unknown	0/0
2135105	Unknown +details Unknown	Unknown	Unknown	0/0
2135104	Unknown +details Unknown	Unknown	Unknown	0/0
2135103	Unknown +details Unknown	Unknown	Unknown	0/0
2135102	Unknown +details Unknown	Unknown	Unknown	0/0
2135101	Unknown +details Unknown	Unknown	Unknown	0/0
2135100	Unknown +details Unknown	Unknown	Unknown	0/0
2135099	Unknown +details Unknown	Unknown	Unknown	0/0
2135098	Unknown +details Unknown	Unknown	Unknown	0/0
2135097	Unknown +details Unknown	Unknown	Unknown	0/0
2135096	Unknown +details Unknown	Unknown	Unknown	0/0
2135095	Unknown +details Unknown	Unknown	Unknown	0/0
2135094	Unknown +details Unknown	Unknown	Unknown	0/0
2135093	Unknown +details Unknown	Unknown	Unknown	0/0
2135092	Unknown +details Unknown	Unknown	Unknown	0/0
2135091	Unknown +details Unknown	Unknown	Unknown	0/0
2135090	Unknown +details Unknown	Unknown	Unknown	0/0
2135089	Unknown +details Unknown	Unknown	Unknown	0/0
2135088	Unknown +details Unknown	Unknown	Unknown	0/0
2135087	Unknown +details Unknown	Unknown	Unknown	0/0
2135086	Unknown +details Unknown	Unknown	Unknown	0/0
2135085	Unknown +details Unknown	Unknown	Unknown	0/0
2135084	Unknown +details Unknown	Unknown	Unknown	0/0

Page: