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

Status: SUCCEEDED
Submitted: 2026/08/31 14:18:44
Duration: 0.7 s
Associated SQL Query: 13376
Job Group: 3bab42a5-b044-4db1-bce4-9536b8a66679
Completed Stages: 2
Skipped Stages: 166

Event Timeline

Enable zooming

No DAG visualization information to display for job 18567

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
334171	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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/08/31 14:18:44	0.2 s	30/30
334170	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 start at FileStorageAdapterImpl.java:596 +details RDD: (1) Filter (isnotnull(shardId#3579691) AND (shardId#3579691 = 0_1_10000000532)) +- (1) Scan ExistingRDD[shardId#3579691,orderProposalId#3579692L,items#3579693,optimizationGroups#3579694,isOptimal#3579695,lastModified#3579696,optimizationInsights#3579697] 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/08/31 14:18:44	0.5 s	30/30	1628.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

334171

tenants-pool-506

stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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/08/31 14:18:44

0.2 s

30/30

334170

tenants-pool-506

stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 start at FileStorageAdapterImpl.java:596 +details

RDD: *(1) Filter (isnotnull(shardId#3579691) AND (shardId#3579691 = 0_1_10000000532)) +- *(1) Scan ExistingRDD[shardId#3579691,orderProposalId#3579692L,items#3579693,optimizationGroups#3579694,isOptimal#3579695,lastModified#3579696,optimizationInsights#3579697]

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/08/31 14:18:44

0.5 s

30/30

1628.1 KiB

Page:

Skipped Stages (166)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
334169	Unknown +details Unknown	Unknown	Unknown	0/0
334168	Unknown +details Unknown	Unknown	Unknown	0/0
334167	Unknown +details Unknown	Unknown	Unknown	0/0
334166	Unknown +details Unknown	Unknown	Unknown	0/0
334165	Unknown +details Unknown	Unknown	Unknown	0/0
334164	Unknown +details Unknown	Unknown	Unknown	0/0
334163	Unknown +details Unknown	Unknown	Unknown	0/0
334162	Unknown +details Unknown	Unknown	Unknown	0/0
334161	Unknown +details Unknown	Unknown	Unknown	0/0
334160	Unknown +details Unknown	Unknown	Unknown	0/0
334159	Unknown +details Unknown	Unknown	Unknown	0/0
334158	Unknown +details Unknown	Unknown	Unknown	0/0
334157	Unknown +details Unknown	Unknown	Unknown	0/0
334156	Unknown +details Unknown	Unknown	Unknown	0/0
334155	Unknown +details Unknown	Unknown	Unknown	0/0
334154	Unknown +details Unknown	Unknown	Unknown	0/0
334153	Unknown +details Unknown	Unknown	Unknown	0/0
334152	Unknown +details Unknown	Unknown	Unknown	0/0
334151	Unknown +details Unknown	Unknown	Unknown	0/0
334150	Unknown +details Unknown	Unknown	Unknown	0/0
334149	Unknown +details Unknown	Unknown	Unknown	0/0
334148	Unknown +details Unknown	Unknown	Unknown	0/0
334147	Unknown +details Unknown	Unknown	Unknown	0/0
334146	Unknown +details Unknown	Unknown	Unknown	0/0
334145	Unknown +details Unknown	Unknown	Unknown	0/0
334144	Unknown +details Unknown	Unknown	Unknown	0/0
334143	Unknown +details Unknown	Unknown	Unknown	0/0
334142	Unknown +details Unknown	Unknown	Unknown	0/0
334141	Unknown +details Unknown	Unknown	Unknown	0/0
334140	Unknown +details Unknown	Unknown	Unknown	0/0
334139	Unknown +details Unknown	Unknown	Unknown	0/0
334138	Unknown +details Unknown	Unknown	Unknown	0/0
334137	Unknown +details Unknown	Unknown	Unknown	0/0
334136	Unknown +details Unknown	Unknown	Unknown	0/0
334135	Unknown +details Unknown	Unknown	Unknown	0/0
334134	Unknown +details Unknown	Unknown	Unknown	0/0
334133	Unknown +details Unknown	Unknown	Unknown	0/0
334132	Unknown +details Unknown	Unknown	Unknown	0/0
334131	Unknown +details Unknown	Unknown	Unknown	0/0
334130	Unknown +details Unknown	Unknown	Unknown	0/0
334129	Unknown +details Unknown	Unknown	Unknown	0/0
334128	Unknown +details Unknown	Unknown	Unknown	0/0
334127	Unknown +details Unknown	Unknown	Unknown	0/0
334126	Unknown +details Unknown	Unknown	Unknown	0/0
334125	Unknown +details Unknown	Unknown	Unknown	0/0
334124	Unknown +details Unknown	Unknown	Unknown	0/0
334123	Unknown +details Unknown	Unknown	Unknown	0/0
334122	Unknown +details Unknown	Unknown	Unknown	0/0
334121	Unknown +details Unknown	Unknown	Unknown	0/0
334120	Unknown +details Unknown	Unknown	Unknown	0/0
334119	Unknown +details Unknown	Unknown	Unknown	0/0
334118	Unknown +details Unknown	Unknown	Unknown	0/0
334117	Unknown +details Unknown	Unknown	Unknown	0/0
334116	Unknown +details Unknown	Unknown	Unknown	0/0
334115	Unknown +details Unknown	Unknown	Unknown	0/0
334114	Unknown +details Unknown	Unknown	Unknown	0/0
334113	Unknown +details Unknown	Unknown	Unknown	0/0
334112	Unknown +details Unknown	Unknown	Unknown	0/0
334111	Unknown +details Unknown	Unknown	Unknown	0/0
334110	Unknown +details Unknown	Unknown	Unknown	0/0
334109	Unknown +details Unknown	Unknown	Unknown	0/0
334108	Unknown +details Unknown	Unknown	Unknown	0/0
334107	Unknown +details Unknown	Unknown	Unknown	0/0
334106	Unknown +details Unknown	Unknown	Unknown	0/0
334105	Unknown +details Unknown	Unknown	Unknown	0/0
334104	Unknown +details Unknown	Unknown	Unknown	0/0
334103	Unknown +details Unknown	Unknown	Unknown	0/0
334102	Unknown +details Unknown	Unknown	Unknown	0/0
334101	Unknown +details Unknown	Unknown	Unknown	0/0
334100	Unknown +details Unknown	Unknown	Unknown	0/0
334099	Unknown +details Unknown	Unknown	Unknown	0/0
334098	Unknown +details Unknown	Unknown	Unknown	0/0
334097	Unknown +details Unknown	Unknown	Unknown	0/0
334096	Unknown +details Unknown	Unknown	Unknown	0/0
334095	Unknown +details Unknown	Unknown	Unknown	0/0
334094	Unknown +details Unknown	Unknown	Unknown	0/0
334093	Unknown +details Unknown	Unknown	Unknown	0/0
334092	Unknown +details Unknown	Unknown	Unknown	0/0
334091	Unknown +details Unknown	Unknown	Unknown	0/0
334090	Unknown +details Unknown	Unknown	Unknown	0/0
334089	Unknown +details Unknown	Unknown	Unknown	0/0
334088	Unknown +details Unknown	Unknown	Unknown	0/0
334087	Unknown +details Unknown	Unknown	Unknown	0/0
334086	Unknown +details Unknown	Unknown	Unknown	0/0
334085	Unknown +details Unknown	Unknown	Unknown	0/0
334084	Unknown +details Unknown	Unknown	Unknown	0/0
334083	Unknown +details Unknown	Unknown	Unknown	0/0
334082	Unknown +details Unknown	Unknown	Unknown	0/0
334081	Unknown +details Unknown	Unknown	Unknown	0/0
334080	Unknown +details Unknown	Unknown	Unknown	0/0
334079	Unknown +details Unknown	Unknown	Unknown	0/0
334078	Unknown +details Unknown	Unknown	Unknown	0/0
334077	Unknown +details Unknown	Unknown	Unknown	0/0
334076	Unknown +details Unknown	Unknown	Unknown	0/0
334075	Unknown +details Unknown	Unknown	Unknown	0/0
334074	Unknown +details Unknown	Unknown	Unknown	0/0
334073	Unknown +details Unknown	Unknown	Unknown	0/0
334072	Unknown +details Unknown	Unknown	Unknown	0/0
334071	Unknown +details Unknown	Unknown	Unknown	0/0
334070	Unknown +details Unknown	Unknown	Unknown	0/0

Page: