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

Status: SUCCEEDED
Submitted: 2026/09/03 11:18:53
Duration: 0.7 s
Associated SQL Query: 82795
Job Group: 4bf75fd4-c2e3-496e-bc8a-c063a62efe60
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_2136995"; subgraph graph_stage_2136995 { id="graph_stage_2136995"; isCluster="true"; label="Stage 2136995 (skipped)"; subgraph cluster_2367386 { id="cluster_2367386"; isCluster="true"; label="LocalTableScan"; 943632 [id="node_943632" labelType="html" label="ParallelCollectionRDD [943632] start at FileStorageAdapterImpl.java:596}"]; 943634 [id="node_943634" labelType="html" label="MapPartitionsRDD [943634] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367385 { id="cluster_2367385"; isCluster="true"; label="Exchange"; 943636 [id="node_943636" labelType="html" label="MapPartitionsRDD [943636] start at FileStorageAdapterImpl.java:596}"]; } } 943632->943634; 943634->943636; }

digraph G { id="graph_2136996"; subgraph graph_stage_2136996 { id="graph_stage_2136996"; isCluster="true"; label="Stage 2136996 (skipped)"; subgraph cluster_2367383 { id="cluster_2367383"; isCluster="true"; label="LocalTableScan"; 943637 [id="node_943637" labelType="html" label="ParallelCollectionRDD [943637] start at FileStorageAdapterImpl.java:596}"]; 943638 [id="node_943638" labelType="html" label="MapPartitionsRDD [943638] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367382 { id="cluster_2367382"; isCluster="true"; label="Exchange"; 943639 [id="node_943639" labelType="html" label="MapPartitionsRDD [943639] start at FileStorageAdapterImpl.java:596}"]; } } 943637->943638; 943638->943639; }

digraph G { id="graph_2136997"; subgraph graph_stage_2136997 { id="graph_stage_2136997"; isCluster="true"; label="Stage 2136997 (skipped)"; subgraph cluster_2367399 { id="cluster_2367399"; isCluster="true"; label="AQEShuffleRead"; 943640 [id="node_943640" labelType="html" label="ShuffledRowRDD [943640] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367396 { id="cluster_2367396"; isCluster="true"; label="WholeStageCodegen (1)"; 943641 [id="node_943641" labelType="html" label="MapPartitionsRDD [943641] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367404 { id="cluster_2367404"; isCluster="true"; label="AQEShuffleRead"; 943642 [id="node_943642" labelType="html" label="ShuffledRowRDD [943642] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367401 { id="cluster_2367401"; isCluster="true"; label="WholeStageCodegen (2)"; 943643 [id="node_943643" labelType="html" label="MapPartitionsRDD [943643] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367392 { id="cluster_2367392"; isCluster="true"; label="WholeStageCodegen (3)"; 943644 [id="node_943644" labelType="html" label="ZippedPartitionsRDD2 [943644] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 943645 [id="node_943645" labelType="html" label="MapPartitionsRDD [943645] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367391 { id="cluster_2367391"; isCluster="true"; label="Exchange"; 943646 [id="node_943646" labelType="html" label="MapPartitionsRDD [943646] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 943640->943641; 943642->943643; 943641->943644; 943643->943644; 943644->943645; 943645->943646; }

943639,943640

943636,943642

digraph G { id="graph_2136998"; subgraph graph_stage_2136998 { id="graph_stage_2136998"; isCluster="true"; label="Stage 2136998 (skipped)"; subgraph cluster_2367389 { id="cluster_2367389"; isCluster="true"; label="LocalTableScan"; 943631 [id="node_943631" labelType="html" label="ParallelCollectionRDD [943631] start at FileStorageAdapterImpl.java:596}"]; 943633 [id="node_943633" labelType="html" label="MapPartitionsRDD [943633] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367388 { id="cluster_2367388"; isCluster="true"; label="Exchange"; 943635 [id="node_943635" labelType="html" label="MapPartitionsRDD [943635] start at FileStorageAdapterImpl.java:596}"]; } } 943631->943633; 943633->943635; }

digraph G { id="graph_2136999"; subgraph graph_stage_2136999 { id="graph_stage_2136999"; isCluster="true"; label="Stage 2136999"; subgraph cluster_2367414 { id="cluster_2367414"; isCluster="true"; label="AQEShuffleRead"; 943647 [id="node_943647" labelType="html" label="ShuffledRowRDD [943647] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367411 { id="cluster_2367411"; isCluster="true"; label="WholeStageCodegen (4)"; 943648 [id="node_943648" labelType="html" label="MapPartitionsRDD [943648] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367419 { id="cluster_2367419"; isCluster="true"; label="AQEShuffleRead"; 943649 [id="node_943649" labelType="html" label="ShuffledRowRDD [943649] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367416 { id="cluster_2367416"; isCluster="true"; label="WholeStageCodegen (5)"; 943650 [id="node_943650" labelType="html" label="MapPartitionsRDD [943650] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367406 { id="cluster_2367406"; isCluster="true"; label="WholeStageCodegen (6)"; 943651 [id="node_943651" labelType="html" label="ZippedPartitionsRDD2 [943651] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 943652 [id="node_943652" labelType="html" label="MapPartitionsRDD [943652] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367405 { id="cluster_2367405"; isCluster="true"; label="WriteFiles"; 943653 [id="node_943653" labelType="html" label="MapPartitionsRDD [943653] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 943647->943648; 943649->943650; 943648->943651; 943650->943651; 943651->943652; 943652->943653; }

943646,943647

943635,943649

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
2136999	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:18:53	0.7 s	1/1		43.1 KiB	20.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

2136999

tenants-pool-506

stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:18:53

0.7 s

1/1

43.1 KiB

20.5 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
2136998	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/37
2136997	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
2136996	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/37
2136995	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/37

Page: