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

Status: SUCCEEDED
Submitted: 2026/06/09 15:53:57
Duration: 3 s
Associated SQL Query: 100492
Job Group: 6ced03eb-c046-4d38-8b3d-6156b8f3929b
Completed Stages: 6

Enable zooming

digraph G { id="graph_446283"; subgraph graph_stage_446283 { id="graph_stage_446283"; isCluster="true"; label="Stage 446283"; subgraph cluster_3152196 { id="cluster_3152196"; isCluster="true"; label="Scan parquet "; 1243418 [id="node_1243418" labelType="html" label="FileScanRDD [1243418] start at FileStorageAdapterImpl.java:174}"]; 1243419 [id="node_1243419" labelType="html" label="MapPartitionsRDD [1243419] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152192 { id="cluster_3152192"; isCluster="true"; label="WholeStageCodegen (1)"; 1243420 [id="node_1243420" labelType="html" label="MapPartitionsRDD [1243420] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152191 { id="cluster_3152191"; isCluster="true"; label="Exchange"; 1243421 [id="node_1243421" labelType="html" label="MapPartitionsRDD [1243421] start at FileStorageAdapterImpl.java:174}"]; } } 1243418->1243419; 1243419->1243420; 1243420->1243421; }

digraph G { id="graph_446284"; subgraph graph_stage_446284 { id="graph_stage_446284"; isCluster="true"; label="Stage 446284"; subgraph cluster_3152229 { id="cluster_3152229"; isCluster="true"; label="Scan parquet "; 1243429 [id="node_1243429" labelType="html" label="FileScanRDD [1243429] start at FileStorageAdapterImpl.java:174}"]; 1243430 [id="node_1243430" labelType="html" label="MapPartitionsRDD [1243430] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152225 { id="cluster_3152225"; isCluster="true"; label="WholeStageCodegen (7)"; 1243431 [id="node_1243431" labelType="html" label="MapPartitionsRDD [1243431] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152224 { id="cluster_3152224"; isCluster="true"; label="Exchange"; 1243432 [id="node_1243432" labelType="html" label="MapPartitionsRDD [1243432] start at FileStorageAdapterImpl.java:174}"]; } } 1243429->1243430; 1243430->1243431; 1243431->1243432; }

digraph G { id="graph_446285"; subgraph graph_stage_446285 { id="graph_stage_446285"; isCluster="true"; label="Stage 446285"; subgraph cluster_3152224 { id="cluster_3152224"; isCluster="true"; label="Exchange"; 1243433 [id="node_1243433" labelType="html" label="ShuffledRowRDD [1243433] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152202 { id="cluster_3152202"; isCluster="true"; label="WholeStageCodegen (11)"; 1243434 [id="node_1243434" labelType="html" label="MapPartitionsRDD [1243434] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152201 { id="cluster_3152201"; isCluster="true"; label="Exchange"; 1243435 [id="node_1243435" labelType="html" label="MapPartitionsRDD [1243435] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243433->1243434; 1243434->1243435; }

1243432,1243433

digraph G { id="graph_446286"; subgraph graph_stage_446286 { id="graph_stage_446286"; isCluster="true"; label="Stage 446286"; subgraph cluster_3152191 { id="cluster_3152191"; isCluster="true"; label="Exchange"; 1243422 [id="node_1243422" labelType="html" label="ShuffledRowRDD [1243422] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152170 { id="cluster_3152170"; isCluster="true"; label="WholeStageCodegen (5)"; 1243423 [id="node_1243423" labelType="html" label="MapPartitionsRDD [1243423] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152169 { id="cluster_3152169"; isCluster="true"; label="Exchange"; 1243424 [id="node_1243424" labelType="html" label="MapPartitionsRDD [1243424] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243422->1243423; 1243423->1243424; }

1243421,1243422

digraph G { id="graph_446287"; subgraph graph_stage_446287 { id="graph_stage_446287"; isCluster="true"; label="Stage 446287"; subgraph cluster_3152169 { id="cluster_3152169"; isCluster="true"; label="Exchange"; 1243425 [id="node_1243425" labelType="html" label="ShuffledRowRDD [1243425] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152166 { id="cluster_3152166"; isCluster="true"; label="WholeStageCodegen (6)"; 1243426 [id="node_1243426" labelType="html" label="MapPartitionsRDD [1243426] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152201 { id="cluster_3152201"; isCluster="true"; label="Exchange"; 1243436 [id="node_1243436" labelType="html" label="ShuffledRowRDD [1243436] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152198 { id="cluster_3152198"; isCluster="true"; label="WholeStageCodegen (12)"; 1243437 [id="node_1243437" labelType="html" label="MapPartitionsRDD [1243437] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152162 { id="cluster_3152162"; isCluster="true"; label="WholeStageCodegen (13)"; 1243438 [id="node_1243438" labelType="html" label="ZippedPartitionsRDD2 [1243438] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243439 [id="node_1243439" labelType="html" label="MapPartitionsRDD [1243439] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152161 { id="cluster_3152161"; isCluster="true"; label="ObjectHashAggregate"; 1243440 [id="node_1243440" labelType="html" label="MapPartitionsRDD [1243440] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152160 { id="cluster_3152160"; isCluster="true"; label="Exchange"; 1243441 [id="node_1243441" labelType="html" label="MapPartitionsRDD [1243441] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243425->1243426; 1243436->1243437; 1243426->1243438; 1243437->1243438; 1243438->1243439; 1243439->1243440; 1243440->1243441; }

1243424,1243425

1243435,1243436

digraph G { id="graph_446288"; subgraph graph_stage_446288 { id="graph_stage_446288"; isCluster="true"; label="Stage 446288"; 1243450 [id="node_1243450" labelType="html" label="SQLExecutionRDD [1243450] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152160 { id="cluster_3152160"; isCluster="true"; label="Exchange"; 1243442 [id="node_1243442" labelType="html" label="ShuffledRowRDD [1243442] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152159 { id="cluster_3152159"; isCluster="true"; label="ObjectHashAggregate"; 1243443 [id="node_1243443" labelType="html" label="MapPartitionsRDD [1243443] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152158 { id="cluster_3152158"; isCluster="true"; label="Project"; 1243444 [id="node_1243444" labelType="html" label="MapPartitionsRDD [1243444] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152151 { id="cluster_3152151"; isCluster="true"; label="WholeStageCodegen (16)"; 1243445 [id="node_1243445" labelType="html" label="MapPartitionsRDD [1243445] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152150 { id="cluster_3152150"; isCluster="true"; label="DeserializeToObject"; 1243446 [id="node_1243446" labelType="html" label="MapPartitionsRDD [1243446] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152149 { id="cluster_3152149"; isCluster="true"; label="MapPartitions"; 1243447 [id="node_1243447" labelType="html" label="MapPartitionsRDD [1243447] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152081 { id="cluster_3152081"; isCluster="true"; label="WholeStageCodegen (19)"; 1243448 [id="node_1243448" labelType="html" label="MapPartitionsRDD [1243448] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152060 { id="cluster_3152060"; isCluster="true"; label="DeserializeToObject"; 1243449 [id="node_1243449" labelType="html" label="MapPartitionsRDD [1243449] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152237 { id="cluster_3152237"; isCluster="true"; label="mapPartitions"; 1243451 [id="node_1243451" labelType="html" label="MapPartitionsRDD [1243451] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152238 { id="cluster_3152238"; isCluster="true"; label="mapPartitions"; 1243452 [id="node_1243452" labelType="html" label="MapPartitionsRDD [1243452] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243442->1243443; 1243443->1243444; 1243444->1243445; 1243445->1243446; 1243446->1243447; 1243447->1243448; 1243448->1243449; 1243449->1243450; 1243450->1243451; 1243451->1243452; }

1243441,1243442

1243452

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
446288	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:58	2 s	20/20	70.2 KiB
446287	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:58	0.5 s	20/20	89.4 KiB	70.2 KiB
446286	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:57	0.2 s	20/20	13.5 KiB	67.7 KiB
446285	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:57	0.2 s	20/20	8.1 KiB	21.7 KiB
446284	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:57	0.2 s	1/1		8.1 KiB
446283	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 7 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:53:57	0.2 s	1/1		13.5 KiB

Page: