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

Status: SUCCEEDED
Submitted: 2026/07/22 02:20:31
Duration: 81 ms
Associated SQL Query: 41208
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 56409

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1568389	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	34 ms	30/30			92.0 B
1568388	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	34 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

1568389

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

34 ms

30/30

92.0 B

1568388

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

34 ms

30/30

923.0 B

92.0 B

Page:

Skipped Stages (73)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1568387	Unknown +details Unknown	Unknown	Unknown	0/0
1568386	Unknown +details Unknown	Unknown	Unknown	0/0
1568385	Unknown +details Unknown	Unknown	Unknown	0/0
1568384	Unknown +details Unknown	Unknown	Unknown	0/0
1568383	Unknown +details Unknown	Unknown	Unknown	0/0
1568382	Unknown +details Unknown	Unknown	Unknown	0/0
1568381	Unknown +details Unknown	Unknown	Unknown	0/0
1568380	Unknown +details Unknown	Unknown	Unknown	0/0
1568379	Unknown +details Unknown	Unknown	Unknown	0/0
1568378	Unknown +details Unknown	Unknown	Unknown	0/0
1568377	Unknown +details Unknown	Unknown	Unknown	0/0
1568376	Unknown +details Unknown	Unknown	Unknown	0/0
1568375	Unknown +details Unknown	Unknown	Unknown	0/0
1568374	Unknown +details Unknown	Unknown	Unknown	0/0
1568373	Unknown +details Unknown	Unknown	Unknown	0/0
1568372	Unknown +details Unknown	Unknown	Unknown	0/0
1568371	Unknown +details Unknown	Unknown	Unknown	0/0
1568370	Unknown +details Unknown	Unknown	Unknown	0/0
1568369	Unknown +details Unknown	Unknown	Unknown	0/0
1568368	Unknown +details Unknown	Unknown	Unknown	0/0
1568367	Unknown +details Unknown	Unknown	Unknown	0/0
1568366	Unknown +details Unknown	Unknown	Unknown	0/0
1568365	Unknown +details Unknown	Unknown	Unknown	0/0
1568364	Unknown +details Unknown	Unknown	Unknown	0/0
1568363	Unknown +details Unknown	Unknown	Unknown	0/0
1568362	Unknown +details Unknown	Unknown	Unknown	0/0
1568361	Unknown +details Unknown	Unknown	Unknown	0/0
1568360	Unknown +details Unknown	Unknown	Unknown	0/0
1568359	Unknown +details Unknown	Unknown	Unknown	0/0
1568358	Unknown +details Unknown	Unknown	Unknown	0/0
1568357	Unknown +details Unknown	Unknown	Unknown	0/0
1568356	Unknown +details Unknown	Unknown	Unknown	0/0
1568355	Unknown +details Unknown	Unknown	Unknown	0/0
1568354	Unknown +details Unknown	Unknown	Unknown	0/0
1568353	Unknown +details Unknown	Unknown	Unknown	0/0
1568352	Unknown +details Unknown	Unknown	Unknown	0/0
1568351	Unknown +details Unknown	Unknown	Unknown	0/0
1568350	Unknown +details Unknown	Unknown	Unknown	0/0
1568349	Unknown +details Unknown	Unknown	Unknown	0/0
1568348	Unknown +details Unknown	Unknown	Unknown	0/0
1568347	Unknown +details Unknown	Unknown	Unknown	0/0
1568346	Unknown +details Unknown	Unknown	Unknown	0/0
1568345	Unknown +details Unknown	Unknown	Unknown	0/0
1568344	Unknown +details Unknown	Unknown	Unknown	0/0
1568343	Unknown +details Unknown	Unknown	Unknown	0/0
1568342	Unknown +details Unknown	Unknown	Unknown	0/0
1568341	Unknown +details Unknown	Unknown	Unknown	0/0
1568340	Unknown +details Unknown	Unknown	Unknown	0/0
1568339	Unknown +details Unknown	Unknown	Unknown	0/0
1568338	Unknown +details Unknown	Unknown	Unknown	0/0
1568337	Unknown +details Unknown	Unknown	Unknown	0/0
1568336	Unknown +details Unknown	Unknown	Unknown	0/0
1568335	Unknown +details Unknown	Unknown	Unknown	0/0
1568334	Unknown +details Unknown	Unknown	Unknown	0/0
1568333	Unknown +details Unknown	Unknown	Unknown	0/0
1568332	Unknown +details Unknown	Unknown	Unknown	0/0
1568331	Unknown +details Unknown	Unknown	Unknown	0/0
1568330	Unknown +details Unknown	Unknown	Unknown	0/0
1568329	Unknown +details Unknown	Unknown	Unknown	0/0
1568328	Unknown +details Unknown	Unknown	Unknown	0/0
1568327	Unknown +details Unknown	Unknown	Unknown	0/0
1568326	Unknown +details Unknown	Unknown	Unknown	0/0
1568325	Unknown +details Unknown	Unknown	Unknown	0/0
1568324	Unknown +details Unknown	Unknown	Unknown	0/0
1568323	Unknown +details Unknown	Unknown	Unknown	0/0
1568322	Unknown +details Unknown	Unknown	Unknown	0/0
1568321	Unknown +details Unknown	Unknown	Unknown	0/0
1568320	Unknown +details Unknown	Unknown	Unknown	0/0
1568319	Unknown +details Unknown	Unknown	Unknown	0/0
1568318	Unknown +details Unknown	Unknown	Unknown	0/0
1568317	Unknown +details Unknown	Unknown	Unknown	0/0
1568316	Unknown +details Unknown	Unknown	Unknown	0/0
1568315	Unknown +details Unknown	Unknown	Unknown	0/0

Page: