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

Status: SUCCEEDED
Submitted: 2026/07/22 02:22:14
Duration: 0.3 s
Associated SQL Query: 41328
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 2
Skipped Stages: 132

Event Timeline

Enable zooming

No DAG visualization information to display for job 56553

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1575178	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 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:22:15	17 ms	30/30			1380.0 B
1575177	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details RDD: (1) Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290)) +- (1) Scan ExistingRDD[shardId#6608407,orderProposalId#6608408L,items#6608409,optimizationGroups#6608410,isOptimal#6608411,lastModified#6608412,optimizationInsights#6608413] 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:22:14	0.3 s	30/30	8.7 KiB			1380.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1575178

tenants-pool-679

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

17 ms

30/30

1380.0 B

1575177

tenants-pool-679

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

RDD: *(1) Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290)) +- *(1) Scan ExistingRDD[shardId#6608407,orderProposalId#6608408L,items#6608409,optimizationGroups#6608410,isOptimal#6608411,lastModified#6608412,optimizationInsights#6608413]

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:22:14

0.3 s

30/30

8.7 KiB

1380.0 B

Page:

Skipped Stages (132)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1575176	Unknown +details Unknown	Unknown	Unknown	0/0
1575175	Unknown +details Unknown	Unknown	Unknown	0/0
1575174	Unknown +details Unknown	Unknown	Unknown	0/0
1575173	Unknown +details Unknown	Unknown	Unknown	0/0
1575172	Unknown +details Unknown	Unknown	Unknown	0/0
1575171	Unknown +details Unknown	Unknown	Unknown	0/0
1575170	Unknown +details Unknown	Unknown	Unknown	0/0
1575169	Unknown +details Unknown	Unknown	Unknown	0/0
1575168	Unknown +details Unknown	Unknown	Unknown	0/0
1575167	Unknown +details Unknown	Unknown	Unknown	0/0
1575166	Unknown +details Unknown	Unknown	Unknown	0/0
1575165	Unknown +details Unknown	Unknown	Unknown	0/0
1575164	Unknown +details Unknown	Unknown	Unknown	0/0
1575163	Unknown +details Unknown	Unknown	Unknown	0/0
1575162	Unknown +details Unknown	Unknown	Unknown	0/0
1575161	Unknown +details Unknown	Unknown	Unknown	0/0
1575160	Unknown +details Unknown	Unknown	Unknown	0/0
1575159	Unknown +details Unknown	Unknown	Unknown	0/0
1575158	Unknown +details Unknown	Unknown	Unknown	0/0
1575157	Unknown +details Unknown	Unknown	Unknown	0/0
1575156	Unknown +details Unknown	Unknown	Unknown	0/0
1575155	Unknown +details Unknown	Unknown	Unknown	0/0
1575154	Unknown +details Unknown	Unknown	Unknown	0/0
1575153	Unknown +details Unknown	Unknown	Unknown	0/0
1575152	Unknown +details Unknown	Unknown	Unknown	0/0
1575151	Unknown +details Unknown	Unknown	Unknown	0/0
1575150	Unknown +details Unknown	Unknown	Unknown	0/0
1575149	Unknown +details Unknown	Unknown	Unknown	0/0
1575148	Unknown +details Unknown	Unknown	Unknown	0/0
1575147	Unknown +details Unknown	Unknown	Unknown	0/0
1575146	Unknown +details Unknown	Unknown	Unknown	0/0
1575145	Unknown +details Unknown	Unknown	Unknown	0/0
1575144	Unknown +details Unknown	Unknown	Unknown	0/0
1575143	Unknown +details Unknown	Unknown	Unknown	0/0
1575142	Unknown +details Unknown	Unknown	Unknown	0/0
1575141	Unknown +details Unknown	Unknown	Unknown	0/0
1575140	Unknown +details Unknown	Unknown	Unknown	0/0
1575139	Unknown +details Unknown	Unknown	Unknown	0/0
1575138	Unknown +details Unknown	Unknown	Unknown	0/0
1575137	Unknown +details Unknown	Unknown	Unknown	0/0
1575136	Unknown +details Unknown	Unknown	Unknown	0/0
1575135	Unknown +details Unknown	Unknown	Unknown	0/0
1575134	Unknown +details Unknown	Unknown	Unknown	0/0
1575133	Unknown +details Unknown	Unknown	Unknown	0/0
1575132	Unknown +details Unknown	Unknown	Unknown	0/0
1575131	Unknown +details Unknown	Unknown	Unknown	0/0
1575130	Unknown +details Unknown	Unknown	Unknown	0/0
1575129	Unknown +details Unknown	Unknown	Unknown	0/0
1575128	Unknown +details Unknown	Unknown	Unknown	0/0
1575127	Unknown +details Unknown	Unknown	Unknown	0/0
1575126	Unknown +details Unknown	Unknown	Unknown	0/0
1575125	Unknown +details Unknown	Unknown	Unknown	0/0
1575124	Unknown +details Unknown	Unknown	Unknown	0/0
1575123	Unknown +details Unknown	Unknown	Unknown	0/0
1575122	Unknown +details Unknown	Unknown	Unknown	0/0
1575121	Unknown +details Unknown	Unknown	Unknown	0/0
1575120	Unknown +details Unknown	Unknown	Unknown	0/0
1575119	Unknown +details Unknown	Unknown	Unknown	0/0
1575118	Unknown +details Unknown	Unknown	Unknown	0/0
1575117	Unknown +details Unknown	Unknown	Unknown	0/0
1575116	Unknown +details Unknown	Unknown	Unknown	0/0
1575115	Unknown +details Unknown	Unknown	Unknown	0/0
1575114	Unknown +details Unknown	Unknown	Unknown	0/0
1575113	Unknown +details Unknown	Unknown	Unknown	0/0
1575112	Unknown +details Unknown	Unknown	Unknown	0/0
1575111	Unknown +details Unknown	Unknown	Unknown	0/0
1575110	Unknown +details Unknown	Unknown	Unknown	0/0
1575109	Unknown +details Unknown	Unknown	Unknown	0/0
1575108	Unknown +details Unknown	Unknown	Unknown	0/0
1575107	Unknown +details Unknown	Unknown	Unknown	0/0
1575106	Unknown +details Unknown	Unknown	Unknown	0/0
1575105	Unknown +details Unknown	Unknown	Unknown	0/0
1575104	Unknown +details Unknown	Unknown	Unknown	0/0
1575103	Unknown +details Unknown	Unknown	Unknown	0/0
1575102	Unknown +details Unknown	Unknown	Unknown	0/0
1575101	Unknown +details Unknown	Unknown	Unknown	0/0
1575100	Unknown +details Unknown	Unknown	Unknown	0/0
1575099	Unknown +details Unknown	Unknown	Unknown	0/0
1575098	Unknown +details Unknown	Unknown	Unknown	0/0
1575097	Unknown +details Unknown	Unknown	Unknown	0/0
1575096	Unknown +details Unknown	Unknown	Unknown	0/0
1575095	Unknown +details Unknown	Unknown	Unknown	0/0
1575094	Unknown +details Unknown	Unknown	Unknown	0/0
1575093	Unknown +details Unknown	Unknown	Unknown	0/0
1575092	Unknown +details Unknown	Unknown	Unknown	0/0
1575091	Unknown +details Unknown	Unknown	Unknown	0/0
1575090	Unknown +details Unknown	Unknown	Unknown	0/0
1575089	Unknown +details Unknown	Unknown	Unknown	0/0
1575088	Unknown +details Unknown	Unknown	Unknown	0/0
1575087	Unknown +details Unknown	Unknown	Unknown	0/0
1575086	Unknown +details Unknown	Unknown	Unknown	0/0
1575085	Unknown +details Unknown	Unknown	Unknown	0/0
1575084	Unknown +details Unknown	Unknown	Unknown	0/0
1575083	Unknown +details Unknown	Unknown	Unknown	0/0
1575082	Unknown +details Unknown	Unknown	Unknown	0/0
1575081	Unknown +details Unknown	Unknown	Unknown	0/0
1575080	Unknown +details Unknown	Unknown	Unknown	0/0
1575079	Unknown +details Unknown	Unknown	Unknown	0/0
1575078	Unknown +details Unknown	Unknown	Unknown	0/0
1575077	Unknown +details Unknown	Unknown	Unknown	0/0

Page: