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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:53
Duration: 0.4 s
Associated SQL Query: 118
Job Group: 4a9fac36-cbda-4d33-921d-3feccc1086b2
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_468 { label="Stage 468 (skipped)"; subgraph cluster3236 { label="LocalTableScan"; 1234 [labelType="html" label="ParallelCollectionRDD [1234] start at FileStorageAdapterImpl.java:529"]; 1235 [labelType="html" label="MapPartitionsRDD [1235] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3235 { label="Exchange"; 1236 [labelType="html" label="MapPartitionsRDD [1236] start at FileStorageAdapterImpl.java:529"]; } } 1234->1235; 1235->1236; }

digraph G { subgraph clusterstage_469 { label="Stage 469 (skipped)"; subgraph cluster3234 { label="LocalTableScan"; 1231 [labelType="html" label="ParallelCollectionRDD [1231] start at FileStorageAdapterImpl.java:529"]; 1232 [labelType="html" label="MapPartitionsRDD [1232] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3233 { label="Exchange"; 1233 [labelType="html" label="MapPartitionsRDD [1233] start at FileStorageAdapterImpl.java:529"]; } } 1231->1232; 1232->1233; }

digraph G { subgraph clusterstage_470 { label="Stage 470 (skipped)"; subgraph cluster3247 { label="AQEShuffleRead"; 1240 [labelType="html" label="ShuffledRowRDD [1240] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3244 { label="WholeStageCodegen (1)"; 1241 [labelType="html" label="MapPartitionsRDD [1241] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3252 { label="AQEShuffleRead"; 1242 [labelType="html" label="ShuffledRowRDD [1242] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3249 { label="WholeStageCodegen (2)"; 1243 [labelType="html" label="MapPartitionsRDD [1243] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3240 { label="WholeStageCodegen (3)"; 1244 [labelType="html" label="ZippedPartitionsRDD2 [1244] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1245 [labelType="html" label="MapPartitionsRDD [1245] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3239 { label="Exchange"; 1246 [labelType="html" label="MapPartitionsRDD [1246] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1240->1241; 1242->1243; 1241->1244; 1243->1244; 1244->1245; 1245->1246; }

1233,1240

1236,1242

digraph G { subgraph clusterstage_471 { label="Stage 471 (skipped)"; subgraph cluster3238 { label="LocalTableScan"; 1237 [labelType="html" label="ParallelCollectionRDD [1237] start at FileStorageAdapterImpl.java:529"]; 1238 [labelType="html" label="MapPartitionsRDD [1238] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3237 { label="Exchange"; 1239 [labelType="html" label="MapPartitionsRDD [1239] start at FileStorageAdapterImpl.java:529"]; } } 1237->1238; 1238->1239; }

digraph G { subgraph clusterstage_472 { label="Stage 472"; subgraph cluster3262 { label="AQEShuffleRead"; 1247 [labelType="html" label="ShuffledRowRDD [1247] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3259 { label="WholeStageCodegen (4)"; 1248 [labelType="html" label="MapPartitionsRDD [1248] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3267 { label="AQEShuffleRead"; 1249 [labelType="html" label="ShuffledRowRDD [1249] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3264 { label="WholeStageCodegen (5)"; 1250 [labelType="html" label="MapPartitionsRDD [1250] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3254 { label="WholeStageCodegen (6)"; 1251 [labelType="html" label="ZippedPartitionsRDD2 [1251] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1252 [labelType="html" label="MapPartitionsRDD [1252] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3253 { label="WriteFiles"; 1253 [labelType="html" label="MapPartitionsRDD [1253] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1247->1248; 1249->1250; 1248->1251; 1250->1251; 1251->1252; 1252->1253; }

1246,1247

1239,1249

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
472	tenants-pool-286	stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/02/06 10:33:53	0.4 s	1/1		31.1 KiB	1405.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

472

tenants-pool-286

stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/02/06 10:33:53

0.4 s

1/1

31.1 KiB

1405.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
471	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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)	Unknown	Unknown	0/4
470	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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)	Unknown	Unknown	0/1
469	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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)	Unknown	Unknown	0/4
468	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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)	Unknown	Unknown	0/4

Page: