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

Status: SUCCEEDED
Submitted: 2026/08/31 14:23:00
Duration: 2 s
Associated SQL Query: 13535
Job Group: 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_341255"; subgraph graph_stage_341255 { id="graph_stage_341255"; isCluster="true"; label="Stage 341255 (skipped)"; subgraph cluster_385913 { id="cluster_385913"; isCluster="true"; label="LocalTableScan"; 154329 [id="node_154329" labelType="html" label="ParallelCollectionRDD [154329] start at FileStorageAdapterImpl.java:596}"]; 154330 [id="node_154330" labelType="html" label="MapPartitionsRDD [154330] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385912 { id="cluster_385912"; isCluster="true"; label="Exchange"; 154331 [id="node_154331" labelType="html" label="MapPartitionsRDD [154331] start at FileStorageAdapterImpl.java:596}"]; } } 154329->154330; 154330->154331; }

digraph G { id="graph_341256"; subgraph graph_stage_341256 { id="graph_stage_341256"; isCluster="true"; label="Stage 341256 (skipped)"; subgraph cluster_385916 { id="cluster_385916"; isCluster="true"; label="LocalTableScan"; 154323 [id="node_154323" labelType="html" label="ParallelCollectionRDD [154323] start at FileStorageAdapterImpl.java:596}"]; 154325 [id="node_154325" labelType="html" label="MapPartitionsRDD [154325] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385915 { id="cluster_385915"; isCluster="true"; label="Exchange"; 154326 [id="node_154326" labelType="html" label="MapPartitionsRDD [154326] start at FileStorageAdapterImpl.java:596}"]; } } 154323->154325; 154325->154326; }

digraph G { id="graph_341257"; subgraph graph_stage_341257 { id="graph_stage_341257"; isCluster="true"; label="Stage 341257 (skipped)"; subgraph cluster_385929 { id="cluster_385929"; isCluster="true"; label="AQEShuffleRead"; 154332 [id="node_154332" labelType="html" label="ShuffledRowRDD [154332] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385926 { id="cluster_385926"; isCluster="true"; label="WholeStageCodegen (1)"; 154333 [id="node_154333" labelType="html" label="MapPartitionsRDD [154333] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385934 { id="cluster_385934"; isCluster="true"; label="AQEShuffleRead"; 154334 [id="node_154334" labelType="html" label="ShuffledRowRDD [154334] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385931 { id="cluster_385931"; isCluster="true"; label="WholeStageCodegen (2)"; 154335 [id="node_154335" labelType="html" label="MapPartitionsRDD [154335] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385922 { id="cluster_385922"; isCluster="true"; label="WholeStageCodegen (3)"; 154336 [id="node_154336" labelType="html" label="ZippedPartitionsRDD2 [154336] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154337 [id="node_154337" labelType="html" label="MapPartitionsRDD [154337] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385921 { id="cluster_385921"; isCluster="true"; label="Exchange"; 154338 [id="node_154338" labelType="html" label="MapPartitionsRDD [154338] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154332->154333; 154334->154335; 154333->154336; 154335->154336; 154336->154337; 154337->154338; }

154331,154332

154326,154334

digraph G { id="graph_341258"; subgraph graph_stage_341258 { id="graph_stage_341258"; isCluster="true"; label="Stage 341258 (skipped)"; subgraph cluster_385919 { id="cluster_385919"; isCluster="true"; label="LocalTableScan"; 154324 [id="node_154324" labelType="html" label="ParallelCollectionRDD [154324] start at FileStorageAdapterImpl.java:596}"]; 154327 [id="node_154327" labelType="html" label="MapPartitionsRDD [154327] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385918 { id="cluster_385918"; isCluster="true"; label="Exchange"; 154328 [id="node_154328" labelType="html" label="MapPartitionsRDD [154328] start at FileStorageAdapterImpl.java:596}"]; } } 154324->154327; 154327->154328; }

digraph G { id="graph_341259"; subgraph graph_stage_341259 { id="graph_stage_341259"; isCluster="true"; label="Stage 341259"; subgraph cluster_385944 { id="cluster_385944"; isCluster="true"; label="AQEShuffleRead"; 154339 [id="node_154339" labelType="html" label="ShuffledRowRDD [154339] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385941 { id="cluster_385941"; isCluster="true"; label="WholeStageCodegen (4)"; 154340 [id="node_154340" labelType="html" label="MapPartitionsRDD [154340] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385949 { id="cluster_385949"; isCluster="true"; label="AQEShuffleRead"; 154341 [id="node_154341" labelType="html" label="ShuffledRowRDD [154341] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385946 { id="cluster_385946"; isCluster="true"; label="WholeStageCodegen (5)"; 154342 [id="node_154342" labelType="html" label="MapPartitionsRDD [154342] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385936 { id="cluster_385936"; isCluster="true"; label="WholeStageCodegen (6)"; 154343 [id="node_154343" labelType="html" label="ZippedPartitionsRDD2 [154343] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154344 [id="node_154344" labelType="html" label="MapPartitionsRDD [154344] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385935 { id="cluster_385935"; isCluster="true"; label="WriteFiles"; 154345 [id="node_154345" labelType="html" label="MapPartitionsRDD [154345] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154339->154340; 154341->154342; 154340->154343; 154342->154343; 154343->154344; 154344->154345; }

154338,154339

154328,154341

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341259	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:23:00	2 s	1/1		32.9 KiB	1967.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341259

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:23:00

2 s

1/1

32.9 KiB

1967.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341258	default	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)	Unknown	Unknown	0/5
341257	default	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)	Unknown	Unknown	0/1
341256	default	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)	Unknown	Unknown	0/5
341255	default	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)	Unknown	Unknown	0/5

Page: