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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:44
Duration: 1 s
Associated SQL Query: 13531
Job Group: 21238029-8f83-4dda-9603-e1612427f49b
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_341229"; subgraph graph_stage_341229 { id="graph_stage_341229"; isCluster="true"; label="Stage 341229 (skipped)"; subgraph cluster_385761 { id="cluster_385761"; isCluster="true"; label="LocalTableScan"; 154268 [id="node_154268" labelType="html" label="ParallelCollectionRDD [154268] start at FileStorageAdapterImpl.java:596}"]; 154269 [id="node_154269" labelType="html" label="MapPartitionsRDD [154269] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385760 { id="cluster_385760"; isCluster="true"; label="Exchange"; 154270 [id="node_154270" labelType="html" label="MapPartitionsRDD [154270] start at FileStorageAdapterImpl.java:596}"]; } } 154268->154269; 154269->154270; }

digraph G { id="graph_341230"; subgraph graph_stage_341230 { id="graph_stage_341230"; isCluster="true"; label="Stage 341230 (skipped)"; subgraph cluster_385764 { id="cluster_385764"; isCluster="true"; label="LocalTableScan"; 154262 [id="node_154262" labelType="html" label="ParallelCollectionRDD [154262] start at FileStorageAdapterImpl.java:596}"]; 154264 [id="node_154264" labelType="html" label="MapPartitionsRDD [154264] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385763 { id="cluster_385763"; isCluster="true"; label="Exchange"; 154266 [id="node_154266" labelType="html" label="MapPartitionsRDD [154266] start at FileStorageAdapterImpl.java:596}"]; } } 154262->154264; 154264->154266; }

digraph G { id="graph_341231"; subgraph graph_stage_341231 { id="graph_stage_341231"; isCluster="true"; label="Stage 341231 (skipped)"; subgraph cluster_385777 { id="cluster_385777"; isCluster="true"; label="AQEShuffleRead"; 154271 [id="node_154271" labelType="html" label="ShuffledRowRDD [154271] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385774 { id="cluster_385774"; isCluster="true"; label="WholeStageCodegen (1)"; 154272 [id="node_154272" labelType="html" label="MapPartitionsRDD [154272] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385782 { id="cluster_385782"; isCluster="true"; label="AQEShuffleRead"; 154273 [id="node_154273" labelType="html" label="ShuffledRowRDD [154273] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385779 { id="cluster_385779"; isCluster="true"; label="WholeStageCodegen (2)"; 154274 [id="node_154274" labelType="html" label="MapPartitionsRDD [154274] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385770 { id="cluster_385770"; isCluster="true"; label="WholeStageCodegen (3)"; 154275 [id="node_154275" labelType="html" label="ZippedPartitionsRDD2 [154275] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154276 [id="node_154276" labelType="html" label="MapPartitionsRDD [154276] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385769 { id="cluster_385769"; isCluster="true"; label="Exchange"; 154277 [id="node_154277" labelType="html" label="MapPartitionsRDD [154277] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154271->154272; 154273->154274; 154272->154275; 154274->154275; 154275->154276; 154276->154277; }

154270,154271

154266,154273

digraph G { id="graph_341232"; subgraph graph_stage_341232 { id="graph_stage_341232"; isCluster="true"; label="Stage 341232 (skipped)"; subgraph cluster_385767 { id="cluster_385767"; isCluster="true"; label="LocalTableScan"; 154263 [id="node_154263" labelType="html" label="ParallelCollectionRDD [154263] start at FileStorageAdapterImpl.java:596}"]; 154265 [id="node_154265" labelType="html" label="MapPartitionsRDD [154265] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385766 { id="cluster_385766"; isCluster="true"; label="Exchange"; 154267 [id="node_154267" labelType="html" label="MapPartitionsRDD [154267] start at FileStorageAdapterImpl.java:596}"]; } } 154263->154265; 154265->154267; }

digraph G { id="graph_341233"; subgraph graph_stage_341233 { id="graph_stage_341233"; isCluster="true"; label="Stage 341233"; subgraph cluster_385792 { id="cluster_385792"; isCluster="true"; label="AQEShuffleRead"; 154278 [id="node_154278" labelType="html" label="ShuffledRowRDD [154278] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385789 { id="cluster_385789"; isCluster="true"; label="WholeStageCodegen (4)"; 154279 [id="node_154279" labelType="html" label="MapPartitionsRDD [154279] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385797 { id="cluster_385797"; isCluster="true"; label="AQEShuffleRead"; 154280 [id="node_154280" labelType="html" label="ShuffledRowRDD [154280] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385794 { id="cluster_385794"; isCluster="true"; label="WholeStageCodegen (5)"; 154281 [id="node_154281" labelType="html" label="MapPartitionsRDD [154281] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385784 { id="cluster_385784"; isCluster="true"; label="WholeStageCodegen (6)"; 154282 [id="node_154282" labelType="html" label="ZippedPartitionsRDD2 [154282] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154283 [id="node_154283" labelType="html" label="MapPartitionsRDD [154283] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385783 { id="cluster_385783"; isCluster="true"; label="WriteFiles"; 154284 [id="node_154284" labelType="html" label="MapPartitionsRDD [154284] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154278->154279; 154280->154281; 154279->154282; 154281->154282; 154282->154283; 154283->154284; }

154277,154278

154267,154280

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341233	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b 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:22:44	1.0 s	1/1		32.9 KiB	1878.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341233

tenants-pool-506

stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b 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:22:44

1.0 s

1/1

32.9 KiB

1878.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341232	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
341231	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
341230	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
341229	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: