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

Status: SUCCEEDED
Submitted: 2026/09/01 14:16:11
Duration: 1 s
Associated SQL Query: 38143
Job Group: 1ebd557e-9283-4610-a07b-41d13bb785c5
Completed Stages: 3
Skipped Stages: 155

Event Timeline

Enable zooming

No DAG visualization information to display for job 52720

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1034432	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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/01 14:16:12	0.7 s	30/30		4.4 MiB	7.5 MiB
1034431	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 start at FileStorageAdapterImpl.java:596 +details RDD: (1) Filter (isnotnull(shardId#10214802) AND (shardId#10214802 = 0_3_10000000540)) +- (1) Scan ExistingRDD[shardId#10214802,orderProposalId#10214803L,items#10214804,optimizationGroups#10214805,isOptimal#10214806,lastModified#10214807,optimizationInsights#10214808] 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/01 14:16:11	0.2 s	30/30	673.1 KiB			875.0 KiB
1034275	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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/01 14:16:11	0.5 s	37/37				6.6 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1034432

tenants-pool-506

stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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/01 14:16:12

0.7 s

30/30

4.4 MiB

7.5 MiB

1034431

tenants-pool-506

stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 start at FileStorageAdapterImpl.java:596 +details

RDD: *(1) Filter (isnotnull(shardId#10214802) AND (shardId#10214802 = 0_3_10000000540)) +- *(1) Scan ExistingRDD[shardId#10214802,orderProposalId#10214803L,items#10214804,optimizationGroups#10214805,isOptimal#10214806,lastModified#10214807,optimizationInsights#10214808]

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/01 14:16:11

0.2 s

30/30

673.1 KiB

875.0 KiB

1034275

tenants-pool-506

stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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/01 14:16:11

0.5 s

37/37

6.6 MiB

Page:

Skipped Stages (155)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1034430	Unknown +details Unknown	Unknown	Unknown	0/0
1034429	Unknown +details Unknown	Unknown	Unknown	0/0
1034428	Unknown +details Unknown	Unknown	Unknown	0/0
1034427	Unknown +details Unknown	Unknown	Unknown	0/0
1034426	Unknown +details Unknown	Unknown	Unknown	0/0
1034425	Unknown +details Unknown	Unknown	Unknown	0/0
1034424	Unknown +details Unknown	Unknown	Unknown	0/0
1034423	Unknown +details Unknown	Unknown	Unknown	0/0
1034422	Unknown +details Unknown	Unknown	Unknown	0/0
1034421	Unknown +details Unknown	Unknown	Unknown	0/0
1034420	Unknown +details Unknown	Unknown	Unknown	0/0
1034419	Unknown +details Unknown	Unknown	Unknown	0/0
1034418	Unknown +details Unknown	Unknown	Unknown	0/0
1034417	Unknown +details Unknown	Unknown	Unknown	0/0
1034416	Unknown +details Unknown	Unknown	Unknown	0/0
1034415	Unknown +details Unknown	Unknown	Unknown	0/0
1034414	Unknown +details Unknown	Unknown	Unknown	0/0
1034413	Unknown +details Unknown	Unknown	Unknown	0/0
1034412	Unknown +details Unknown	Unknown	Unknown	0/0
1034411	Unknown +details Unknown	Unknown	Unknown	0/0
1034410	Unknown +details Unknown	Unknown	Unknown	0/0
1034409	Unknown +details Unknown	Unknown	Unknown	0/0
1034408	Unknown +details Unknown	Unknown	Unknown	0/0
1034407	Unknown +details Unknown	Unknown	Unknown	0/0
1034406	Unknown +details Unknown	Unknown	Unknown	0/0
1034405	Unknown +details Unknown	Unknown	Unknown	0/0
1034404	Unknown +details Unknown	Unknown	Unknown	0/0
1034403	Unknown +details Unknown	Unknown	Unknown	0/0
1034402	Unknown +details Unknown	Unknown	Unknown	0/0
1034401	Unknown +details Unknown	Unknown	Unknown	0/0
1034400	Unknown +details Unknown	Unknown	Unknown	0/0
1034399	Unknown +details Unknown	Unknown	Unknown	0/0
1034398	Unknown +details Unknown	Unknown	Unknown	0/0
1034397	Unknown +details Unknown	Unknown	Unknown	0/0
1034396	Unknown +details Unknown	Unknown	Unknown	0/0
1034395	Unknown +details Unknown	Unknown	Unknown	0/0
1034394	Unknown +details Unknown	Unknown	Unknown	0/0
1034393	Unknown +details Unknown	Unknown	Unknown	0/0
1034392	Unknown +details Unknown	Unknown	Unknown	0/0
1034391	Unknown +details Unknown	Unknown	Unknown	0/0
1034390	Unknown +details Unknown	Unknown	Unknown	0/0
1034389	Unknown +details Unknown	Unknown	Unknown	0/0
1034388	Unknown +details Unknown	Unknown	Unknown	0/0
1034387	Unknown +details Unknown	Unknown	Unknown	0/0
1034386	Unknown +details Unknown	Unknown	Unknown	0/0
1034385	Unknown +details Unknown	Unknown	Unknown	0/0
1034384	Unknown +details Unknown	Unknown	Unknown	0/0
1034383	Unknown +details Unknown	Unknown	Unknown	0/0
1034382	Unknown +details Unknown	Unknown	Unknown	0/0
1034381	Unknown +details Unknown	Unknown	Unknown	0/0
1034380	Unknown +details Unknown	Unknown	Unknown	0/0
1034379	Unknown +details Unknown	Unknown	Unknown	0/0
1034378	Unknown +details Unknown	Unknown	Unknown	0/0
1034377	Unknown +details Unknown	Unknown	Unknown	0/0
1034376	Unknown +details Unknown	Unknown	Unknown	0/0
1034375	Unknown +details Unknown	Unknown	Unknown	0/0
1034374	Unknown +details Unknown	Unknown	Unknown	0/0
1034373	Unknown +details Unknown	Unknown	Unknown	0/0
1034372	Unknown +details Unknown	Unknown	Unknown	0/0
1034371	Unknown +details Unknown	Unknown	Unknown	0/0
1034370	Unknown +details Unknown	Unknown	Unknown	0/0
1034369	Unknown +details Unknown	Unknown	Unknown	0/0
1034368	Unknown +details Unknown	Unknown	Unknown	0/0
1034367	Unknown +details Unknown	Unknown	Unknown	0/0
1034366	Unknown +details Unknown	Unknown	Unknown	0/0
1034365	Unknown +details Unknown	Unknown	Unknown	0/0
1034364	Unknown +details Unknown	Unknown	Unknown	0/0
1034363	Unknown +details Unknown	Unknown	Unknown	0/0
1034362	Unknown +details Unknown	Unknown	Unknown	0/0
1034361	Unknown +details Unknown	Unknown	Unknown	0/0
1034360	Unknown +details Unknown	Unknown	Unknown	0/0
1034359	Unknown +details Unknown	Unknown	Unknown	0/0
1034358	Unknown +details Unknown	Unknown	Unknown	0/0
1034357	Unknown +details Unknown	Unknown	Unknown	0/0
1034356	Unknown +details Unknown	Unknown	Unknown	0/0
1034355	Unknown +details Unknown	Unknown	Unknown	0/0
1034354	Unknown +details Unknown	Unknown	Unknown	0/0
1034353	Unknown +details Unknown	Unknown	Unknown	0/0
1034352	Unknown +details Unknown	Unknown	Unknown	0/0
1034351	Unknown +details Unknown	Unknown	Unknown	0/0
1034350	Unknown +details Unknown	Unknown	Unknown	0/0
1034349	Unknown +details Unknown	Unknown	Unknown	0/0
1034348	Unknown +details Unknown	Unknown	Unknown	0/0
1034347	Unknown +details Unknown	Unknown	Unknown	0/0
1034346	Unknown +details Unknown	Unknown	Unknown	0/0
1034345	Unknown +details Unknown	Unknown	Unknown	0/0
1034344	Unknown +details Unknown	Unknown	Unknown	0/0
1034343	Unknown +details Unknown	Unknown	Unknown	0/0
1034342	Unknown +details Unknown	Unknown	Unknown	0/0
1034341	Unknown +details Unknown	Unknown	Unknown	0/0
1034340	Unknown +details Unknown	Unknown	Unknown	0/0
1034339	Unknown +details Unknown	Unknown	Unknown	0/0
1034338	Unknown +details Unknown	Unknown	Unknown	0/0
1034337	Unknown +details Unknown	Unknown	Unknown	0/0
1034336	Unknown +details Unknown	Unknown	Unknown	0/0
1034335	Unknown +details Unknown	Unknown	Unknown	0/0
1034334	Unknown +details Unknown	Unknown	Unknown	0/0
1034333	Unknown +details Unknown	Unknown	Unknown	0/0
1034332	Unknown +details Unknown	Unknown	Unknown	0/0
1034331	Unknown +details Unknown	Unknown	Unknown	0/0

Page: