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

Status: SUCCEEDED
Submitted: 2026/07/21 20:59:48
Duration: 0.6 s
Associated SQL Query: 34842
Job Group: 881110fc-a22e-43dd-9ef6-858dd65243b7
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_1345889"; subgraph graph_stage_1345889 { id="graph_stage_1345889"; isCluster="true"; label="Stage 1345889 (skipped)"; subgraph cluster_1040945 { id="cluster_1040945"; isCluster="true"; label="LocalTableScan"; 395238 [id="node_395238" labelType="html" label="ParallelCollectionRDD [395238] start at FileStorageAdapterImpl.java:598}"]; 395242 [id="node_395242" labelType="html" label="MapPartitionsRDD [395242] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040944 { id="cluster_1040944"; isCluster="true"; label="Exchange"; 395243 [id="node_395243" labelType="html" label="MapPartitionsRDD [395243] start at FileStorageAdapterImpl.java:598}"]; } } 395238->395242; 395242->395243; }

digraph G { id="graph_1345890"; subgraph graph_stage_1345890 { id="graph_stage_1345890"; isCluster="true"; label="Stage 1345890 (skipped)"; subgraph cluster_1040939 { id="cluster_1040939"; isCluster="true"; label="LocalTableScan"; 395237 [id="node_395237" labelType="html" label="ParallelCollectionRDD [395237] start at FileStorageAdapterImpl.java:598}"]; 395240 [id="node_395240" labelType="html" label="MapPartitionsRDD [395240] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040938 { id="cluster_1040938"; isCluster="true"; label="Exchange"; 395241 [id="node_395241" labelType="html" label="MapPartitionsRDD [395241] start at FileStorageAdapterImpl.java:598}"]; } } 395237->395240; 395240->395241; }

digraph G { id="graph_1345891"; subgraph graph_stage_1345891 { id="graph_stage_1345891"; isCluster="true"; label="Stage 1345891 (skipped)"; subgraph cluster_1040942 { id="cluster_1040942"; isCluster="true"; label="LocalTableScan"; 395239 [id="node_395239" labelType="html" label="ParallelCollectionRDD [395239] start at FileStorageAdapterImpl.java:598}"]; 395244 [id="node_395244" labelType="html" label="MapPartitionsRDD [395244] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040941 { id="cluster_1040941"; isCluster="true"; label="Exchange"; 395245 [id="node_395245" labelType="html" label="MapPartitionsRDD [395245] start at FileStorageAdapterImpl.java:598}"]; } } 395239->395244; 395244->395245; }

digraph G { id="graph_1345892"; subgraph graph_stage_1345892 { id="graph_stage_1345892"; isCluster="true"; label="Stage 1345892 (skipped)"; subgraph cluster_1040955 { id="cluster_1040955"; isCluster="true"; label="AQEShuffleRead"; 395246 [id="node_395246" labelType="html" label="ShuffledRowRDD [395246] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040952 { id="cluster_1040952"; isCluster="true"; label="WholeStageCodegen (1)"; 395247 [id="node_395247" labelType="html" label="MapPartitionsRDD [395247] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040960 { id="cluster_1040960"; isCluster="true"; label="AQEShuffleRead"; 395248 [id="node_395248" labelType="html" label="ShuffledRowRDD [395248] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040957 { id="cluster_1040957"; isCluster="true"; label="WholeStageCodegen (2)"; 395249 [id="node_395249" labelType="html" label="MapPartitionsRDD [395249] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040948 { id="cluster_1040948"; isCluster="true"; label="WholeStageCodegen (3)"; 395250 [id="node_395250" labelType="html" label="ZippedPartitionsRDD2 [395250] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 395251 [id="node_395251" labelType="html" label="MapPartitionsRDD [395251] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040947 { id="cluster_1040947"; isCluster="true"; label="Exchange"; 395252 [id="node_395252" labelType="html" label="MapPartitionsRDD [395252] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 395246->395247; 395248->395249; 395247->395250; 395249->395250; 395250->395251; 395251->395252; }

395241,395246

395245,395248

digraph G { id="graph_1345893"; subgraph graph_stage_1345893 { id="graph_stage_1345893"; isCluster="true"; label="Stage 1345893"; subgraph cluster_1040970 { id="cluster_1040970"; isCluster="true"; label="AQEShuffleRead"; 395253 [id="node_395253" labelType="html" label="ShuffledRowRDD [395253] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040967 { id="cluster_1040967"; isCluster="true"; label="WholeStageCodegen (4)"; 395254 [id="node_395254" labelType="html" label="MapPartitionsRDD [395254] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040975 { id="cluster_1040975"; isCluster="true"; label="AQEShuffleRead"; 395255 [id="node_395255" labelType="html" label="ShuffledRowRDD [395255] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040972 { id="cluster_1040972"; isCluster="true"; label="WholeStageCodegen (5)"; 395256 [id="node_395256" labelType="html" label="MapPartitionsRDD [395256] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040962 { id="cluster_1040962"; isCluster="true"; label="WholeStageCodegen (6)"; 395257 [id="node_395257" labelType="html" label="ZippedPartitionsRDD2 [395257] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 395258 [id="node_395258" labelType="html" label="MapPartitionsRDD [395258] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040961 { id="cluster_1040961"; isCluster="true"; label="WriteFiles"; 395259 [id="node_395259" labelType="html" label="MapPartitionsRDD [395259] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 395253->395254; 395255->395256; 395254->395257; 395256->395257; 395257->395258; 395258->395259; }

395252,395253

395243,395255

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1345893	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 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/21 20:59:48	0.6 s	1/1		43.2 KiB	21.7 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1345893

tenants-pool-169

stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 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/21 20:59:48

0.6 s

1/1

43.2 KiB

21.7 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1345892	default	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)	Unknown	Unknown	0/1
1345891	default	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)	Unknown	Unknown	0/37
1345890	default	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)	Unknown	Unknown	0/37
1345889	default	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)	Unknown	Unknown	0/37

Page: