crp-order-quantity-kpi-service - Details for Job 186

Status: SUCCEEDED
Submitted: 2026/07/19 17:56:27
Duration: 0.7 s
Associated SQL Query: 153
Job Group: a8c33753-89a2-44e3-8dfb-1898d4a2933a
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_369"; subgraph graph_stage_369 { id="graph_stage_369"; isCluster="true"; label="Stage 369 (skipped)"; subgraph cluster_2726 { id="cluster_2726"; isCluster="true"; label="LocalTableScan"; 1144 [id="node_1144" labelType="html" label="ParallelCollectionRDD [1144] start at FileStorageAdapterImpl.java:179}"]; 1145 [id="node_1145" labelType="html" label="MapPartitionsRDD [1145] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2725 { id="cluster_2725"; isCluster="true"; label="Exchange"; 1148 [id="node_1148" labelType="html" label="MapPartitionsRDD [1148] start at FileStorageAdapterImpl.java:179}"]; } } 1144->1145; 1145->1148; }

digraph G { id="graph_370"; subgraph graph_stage_370 { id="graph_stage_370"; isCluster="true"; label="Stage 370 (skipped)"; subgraph cluster_2723 { id="cluster_2723"; isCluster="true"; label="LocalTableScan"; 1149 [id="node_1149" labelType="html" label="ParallelCollectionRDD [1149] start at FileStorageAdapterImpl.java:179}"]; 1150 [id="node_1150" labelType="html" label="MapPartitionsRDD [1150] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2722 { id="cluster_2722"; isCluster="true"; label="Exchange"; 1151 [id="node_1151" labelType="html" label="MapPartitionsRDD [1151] start at FileStorageAdapterImpl.java:179}"]; } } 1149->1150; 1150->1151; }

digraph G { id="graph_371"; subgraph graph_stage_371 { id="graph_stage_371"; isCluster="true"; label="Stage 371 (skipped)"; subgraph cluster_2739 { id="cluster_2739"; isCluster="true"; label="AQEShuffleRead"; 1152 [id="node_1152" labelType="html" label="ShuffledRowRDD [1152] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2736 { id="cluster_2736"; isCluster="true"; label="WholeStageCodegen (1)"; 1153 [id="node_1153" labelType="html" label="MapPartitionsRDD [1153] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2744 { id="cluster_2744"; isCluster="true"; label="AQEShuffleRead"; 1154 [id="node_1154" labelType="html" label="ShuffledRowRDD [1154] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2741 { id="cluster_2741"; isCluster="true"; label="WholeStageCodegen (2)"; 1155 [id="node_1155" labelType="html" label="MapPartitionsRDD [1155] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2732 { id="cluster_2732"; isCluster="true"; label="WholeStageCodegen (3)"; 1156 [id="node_1156" labelType="html" label="ZippedPartitionsRDD2 [1156] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 1157 [id="node_1157" labelType="html" label="MapPartitionsRDD [1157] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2731 { id="cluster_2731"; isCluster="true"; label="Exchange"; 1158 [id="node_1158" labelType="html" label="MapPartitionsRDD [1158] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 1152->1153; 1154->1155; 1153->1156; 1155->1156; 1156->1157; 1157->1158; }

1151,1152

1148,1154

digraph G { id="graph_372"; subgraph graph_stage_372 { id="graph_stage_372"; isCluster="true"; label="Stage 372 (skipped)"; subgraph cluster_2729 { id="cluster_2729"; isCluster="true"; label="LocalTableScan"; 1143 [id="node_1143" labelType="html" label="ParallelCollectionRDD [1143] start at FileStorageAdapterImpl.java:179}"]; 1146 [id="node_1146" labelType="html" label="MapPartitionsRDD [1146] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2728 { id="cluster_2728"; isCluster="true"; label="Exchange"; 1147 [id="node_1147" labelType="html" label="MapPartitionsRDD [1147] start at FileStorageAdapterImpl.java:179}"]; } } 1143->1146; 1146->1147; }

digraph G { id="graph_373"; subgraph graph_stage_373 { id="graph_stage_373"; isCluster="true"; label="Stage 373"; subgraph cluster_2754 { id="cluster_2754"; isCluster="true"; label="AQEShuffleRead"; 1159 [id="node_1159" labelType="html" label="ShuffledRowRDD [1159] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2751 { id="cluster_2751"; isCluster="true"; label="WholeStageCodegen (4)"; 1160 [id="node_1160" labelType="html" label="MapPartitionsRDD [1160] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2759 { id="cluster_2759"; isCluster="true"; label="AQEShuffleRead"; 1161 [id="node_1161" labelType="html" label="ShuffledRowRDD [1161] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2756 { id="cluster_2756"; isCluster="true"; label="WholeStageCodegen (5)"; 1162 [id="node_1162" labelType="html" label="MapPartitionsRDD [1162] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2746 { id="cluster_2746"; isCluster="true"; label="WholeStageCodegen (6)"; 1163 [id="node_1163" labelType="html" label="ZippedPartitionsRDD2 [1163] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 1164 [id="node_1164" labelType="html" label="MapPartitionsRDD [1164] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2745 { id="cluster_2745"; isCluster="true"; label="WriteFiles"; 1165 [id="node_1165" labelType="html" label="MapPartitionsRDD [1165] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 1159->1160; 1161->1162; 1160->1163; 1162->1163; 1163->1164; 1164->1165; }

1158,1159

1147,1161

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
373	tenants-pool-562	stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/07/19 17:56:27	0.7 s	1/1		32.5 KiB	1389.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

373

tenants-pool-562

stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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/07/19 17:56:27

0.7 s

1/1

32.5 KiB

1389.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
372	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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
371	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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
370	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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
369	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: