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

Status: SUCCEEDED
Submitted: 2026/07/22 02:20:31
Duration: 79 ms
Associated SQL Query: 41207
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 2
Skipped Stages: 73

Event Timeline

Enable zooming

No DAG visualization information to display for job 56408

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1568314	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 45 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:20:31	33 ms	30/30			92.0 B
1568313	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 45 start at FileStorageAdapterImpl.java:598 +details RDD: MapPartitionsRDD 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:20:31	36 ms	30/30	923.0 B			92.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1568314

tenants-pool-679

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

33 ms

30/30

92.0 B

1568313

tenants-pool-679

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

RDD: MapPartitionsRDD

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:20:31

36 ms

30/30

923.0 B

92.0 B

Page:

Skipped Stages (73)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1568312	Unknown +details Unknown	Unknown	Unknown	0/0
1568311	Unknown +details Unknown	Unknown	Unknown	0/0
1568310	Unknown +details Unknown	Unknown	Unknown	0/0
1568309	Unknown +details Unknown	Unknown	Unknown	0/0
1568308	Unknown +details Unknown	Unknown	Unknown	0/0
1568307	Unknown +details Unknown	Unknown	Unknown	0/0
1568306	Unknown +details Unknown	Unknown	Unknown	0/0
1568305	Unknown +details Unknown	Unknown	Unknown	0/0
1568304	Unknown +details Unknown	Unknown	Unknown	0/0
1568303	Unknown +details Unknown	Unknown	Unknown	0/0
1568302	Unknown +details Unknown	Unknown	Unknown	0/0
1568301	Unknown +details Unknown	Unknown	Unknown	0/0
1568300	Unknown +details Unknown	Unknown	Unknown	0/0
1568299	Unknown +details Unknown	Unknown	Unknown	0/0
1568298	Unknown +details Unknown	Unknown	Unknown	0/0
1568297	Unknown +details Unknown	Unknown	Unknown	0/0
1568296	Unknown +details Unknown	Unknown	Unknown	0/0
1568295	Unknown +details Unknown	Unknown	Unknown	0/0
1568294	Unknown +details Unknown	Unknown	Unknown	0/0
1568293	Unknown +details Unknown	Unknown	Unknown	0/0
1568292	Unknown +details Unknown	Unknown	Unknown	0/0
1568291	Unknown +details Unknown	Unknown	Unknown	0/0
1568290	Unknown +details Unknown	Unknown	Unknown	0/0
1568289	Unknown +details Unknown	Unknown	Unknown	0/0
1568288	Unknown +details Unknown	Unknown	Unknown	0/0
1568287	Unknown +details Unknown	Unknown	Unknown	0/0
1568286	Unknown +details Unknown	Unknown	Unknown	0/0
1568285	Unknown +details Unknown	Unknown	Unknown	0/0
1568284	Unknown +details Unknown	Unknown	Unknown	0/0
1568283	Unknown +details Unknown	Unknown	Unknown	0/0
1568282	Unknown +details Unknown	Unknown	Unknown	0/0
1568281	Unknown +details Unknown	Unknown	Unknown	0/0
1568280	Unknown +details Unknown	Unknown	Unknown	0/0
1568279	Unknown +details Unknown	Unknown	Unknown	0/0
1568278	Unknown +details Unknown	Unknown	Unknown	0/0
1568277	Unknown +details Unknown	Unknown	Unknown	0/0
1568276	Unknown +details Unknown	Unknown	Unknown	0/0
1568275	Unknown +details Unknown	Unknown	Unknown	0/0
1568274	Unknown +details Unknown	Unknown	Unknown	0/0
1568273	Unknown +details Unknown	Unknown	Unknown	0/0
1568272	Unknown +details Unknown	Unknown	Unknown	0/0
1568271	Unknown +details Unknown	Unknown	Unknown	0/0
1568270	Unknown +details Unknown	Unknown	Unknown	0/0
1568269	Unknown +details Unknown	Unknown	Unknown	0/0
1568268	Unknown +details Unknown	Unknown	Unknown	0/0
1568267	Unknown +details Unknown	Unknown	Unknown	0/0
1568266	Unknown +details Unknown	Unknown	Unknown	0/0
1568265	Unknown +details Unknown	Unknown	Unknown	0/0
1568264	Unknown +details Unknown	Unknown	Unknown	0/0
1568263	Unknown +details Unknown	Unknown	Unknown	0/0
1568262	Unknown +details Unknown	Unknown	Unknown	0/0
1568261	Unknown +details Unknown	Unknown	Unknown	0/0
1568260	Unknown +details Unknown	Unknown	Unknown	0/0
1568259	Unknown +details Unknown	Unknown	Unknown	0/0
1568258	Unknown +details Unknown	Unknown	Unknown	0/0
1568257	Unknown +details Unknown	Unknown	Unknown	0/0
1568256	Unknown +details Unknown	Unknown	Unknown	0/0
1568255	Unknown +details Unknown	Unknown	Unknown	0/0
1568254	Unknown +details Unknown	Unknown	Unknown	0/0
1568253	Unknown +details Unknown	Unknown	Unknown	0/0
1568252	Unknown +details Unknown	Unknown	Unknown	0/0
1568251	Unknown +details Unknown	Unknown	Unknown	0/0
1568250	Unknown +details Unknown	Unknown	Unknown	0/0
1568249	Unknown +details Unknown	Unknown	Unknown	0/0
1568248	Unknown +details Unknown	Unknown	Unknown	0/0
1568247	Unknown +details Unknown	Unknown	Unknown	0/0
1568246	Unknown +details Unknown	Unknown	Unknown	0/0
1568245	Unknown +details Unknown	Unknown	Unknown	0/0
1568244	Unknown +details Unknown	Unknown	Unknown	0/0
1568243	Unknown +details Unknown	Unknown	Unknown	0/0
1568242	Unknown +details Unknown	Unknown	Unknown	0/0
1568241	Unknown +details Unknown	Unknown	Unknown	0/0
1568240	Unknown +details Unknown	Unknown	Unknown	0/0

Page: