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

Status: SUCCEEDED
Submitted: 2026/06/09 15:55:46
Duration: 2 s
Associated SQL Query: 100549
Job Group: 6ced03eb-c046-4d38-8b3d-6156b8f3929b
Completed Stages: 6

Enable zooming

digraph G { id="graph_446511"; subgraph graph_stage_446511 { id="graph_stage_446511"; isCluster="true"; label="Stage 446511"; subgraph cluster_3153850 { id="cluster_3153850"; isCluster="true"; label="Scan parquet "; 1244092 [id="node_1244092" labelType="html" label="FileScanRDD [1244092] start at FileStorageAdapterImpl.java:174}"]; 1244093 [id="node_1244093" labelType="html" label="MapPartitionsRDD [1244093] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153846 { id="cluster_3153846"; isCluster="true"; label="WholeStageCodegen (7)"; 1244094 [id="node_1244094" labelType="html" label="MapPartitionsRDD [1244094] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153845 { id="cluster_3153845"; isCluster="true"; label="Exchange"; 1244095 [id="node_1244095" labelType="html" label="MapPartitionsRDD [1244095] start at FileStorageAdapterImpl.java:174}"]; } } 1244092->1244093; 1244093->1244094; 1244094->1244095; }

digraph G { id="graph_446512"; subgraph graph_stage_446512 { id="graph_stage_446512"; isCluster="true"; label="Stage 446512"; subgraph cluster_3153817 { id="cluster_3153817"; isCluster="true"; label="Scan parquet "; 1244081 [id="node_1244081" labelType="html" label="FileScanRDD [1244081] start at FileStorageAdapterImpl.java:174}"]; 1244082 [id="node_1244082" labelType="html" label="MapPartitionsRDD [1244082] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153813 { id="cluster_3153813"; isCluster="true"; label="WholeStageCodegen (1)"; 1244083 [id="node_1244083" labelType="html" label="MapPartitionsRDD [1244083] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153812 { id="cluster_3153812"; isCluster="true"; label="Exchange"; 1244084 [id="node_1244084" labelType="html" label="MapPartitionsRDD [1244084] start at FileStorageAdapterImpl.java:174}"]; } } 1244081->1244082; 1244082->1244083; 1244083->1244084; }

digraph G { id="graph_446513"; subgraph graph_stage_446513 { id="graph_stage_446513"; isCluster="true"; label="Stage 446513"; subgraph cluster_3153812 { id="cluster_3153812"; isCluster="true"; label="Exchange"; 1244085 [id="node_1244085" labelType="html" label="ShuffledRowRDD [1244085] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153791 { id="cluster_3153791"; isCluster="true"; label="WholeStageCodegen (5)"; 1244086 [id="node_1244086" labelType="html" label="MapPartitionsRDD [1244086] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153790 { id="cluster_3153790"; isCluster="true"; label="Exchange"; 1244087 [id="node_1244087" labelType="html" label="MapPartitionsRDD [1244087] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244085->1244086; 1244086->1244087; }

1244084,1244085

digraph G { id="graph_446514"; subgraph graph_stage_446514 { id="graph_stage_446514"; isCluster="true"; label="Stage 446514"; subgraph cluster_3153845 { id="cluster_3153845"; isCluster="true"; label="Exchange"; 1244096 [id="node_1244096" labelType="html" label="ShuffledRowRDD [1244096] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153823 { id="cluster_3153823"; isCluster="true"; label="WholeStageCodegen (11)"; 1244097 [id="node_1244097" labelType="html" label="MapPartitionsRDD [1244097] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153822 { id="cluster_3153822"; isCluster="true"; label="Exchange"; 1244098 [id="node_1244098" labelType="html" label="MapPartitionsRDD [1244098] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244096->1244097; 1244097->1244098; }

1244095,1244096

digraph G { id="graph_446515"; subgraph graph_stage_446515 { id="graph_stage_446515"; isCluster="true"; label="Stage 446515"; subgraph cluster_3153790 { id="cluster_3153790"; isCluster="true"; label="Exchange"; 1244088 [id="node_1244088" labelType="html" label="ShuffledRowRDD [1244088] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153787 { id="cluster_3153787"; isCluster="true"; label="WholeStageCodegen (6)"; 1244089 [id="node_1244089" labelType="html" label="MapPartitionsRDD [1244089] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153822 { id="cluster_3153822"; isCluster="true"; label="Exchange"; 1244099 [id="node_1244099" labelType="html" label="ShuffledRowRDD [1244099] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153819 { id="cluster_3153819"; isCluster="true"; label="WholeStageCodegen (12)"; 1244100 [id="node_1244100" labelType="html" label="MapPartitionsRDD [1244100] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153783 { id="cluster_3153783"; isCluster="true"; label="WholeStageCodegen (13)"; 1244101 [id="node_1244101" labelType="html" label="ZippedPartitionsRDD2 [1244101] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1244102 [id="node_1244102" labelType="html" label="MapPartitionsRDD [1244102] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153782 { id="cluster_3153782"; isCluster="true"; label="ObjectHashAggregate"; 1244103 [id="node_1244103" labelType="html" label="MapPartitionsRDD [1244103] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153781 { id="cluster_3153781"; isCluster="true"; label="Exchange"; 1244104 [id="node_1244104" labelType="html" label="MapPartitionsRDD [1244104] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244088->1244089; 1244099->1244100; 1244089->1244101; 1244100->1244101; 1244101->1244102; 1244102->1244103; 1244103->1244104; }

1244087,1244088

1244098,1244099

digraph G { id="graph_446516"; subgraph graph_stage_446516 { id="graph_stage_446516"; isCluster="true"; label="Stage 446516"; 1244113 [id="node_1244113" labelType="html" label="SQLExecutionRDD [1244113] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3153781 { id="cluster_3153781"; isCluster="true"; label="Exchange"; 1244105 [id="node_1244105" labelType="html" label="ShuffledRowRDD [1244105] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153780 { id="cluster_3153780"; isCluster="true"; label="ObjectHashAggregate"; 1244106 [id="node_1244106" labelType="html" label="MapPartitionsRDD [1244106] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153779 { id="cluster_3153779"; isCluster="true"; label="Project"; 1244107 [id="node_1244107" labelType="html" label="MapPartitionsRDD [1244107] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153772 { id="cluster_3153772"; isCluster="true"; label="WholeStageCodegen (16)"; 1244108 [id="node_1244108" labelType="html" label="MapPartitionsRDD [1244108] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153771 { id="cluster_3153771"; isCluster="true"; label="DeserializeToObject"; 1244109 [id="node_1244109" labelType="html" label="MapPartitionsRDD [1244109] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153747 { id="cluster_3153747"; isCluster="true"; label="MapPartitions"; 1244110 [id="node_1244110" labelType="html" label="MapPartitionsRDD [1244110] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153702 { id="cluster_3153702"; isCluster="true"; label="WholeStageCodegen (19)"; 1244111 [id="node_1244111" labelType="html" label="MapPartitionsRDD [1244111] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153681 { id="cluster_3153681"; isCluster="true"; label="DeserializeToObject"; 1244112 [id="node_1244112" labelType="html" label="MapPartitionsRDD [1244112] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153858 { id="cluster_3153858"; isCluster="true"; label="mapPartitions"; 1244114 [id="node_1244114" labelType="html" label="MapPartitionsRDD [1244114] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153859 { id="cluster_3153859"; isCluster="true"; label="mapPartitions"; 1244115 [id="node_1244115" labelType="html" label="MapPartitionsRDD [1244115] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244105->1244106; 1244106->1244107; 1244107->1244108; 1244108->1244109; 1244109->1244110; 1244110->1244111; 1244111->1244112; 1244112->1244113; 1244113->1244114; 1244114->1244115; }

1244104,1244105

1244115

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
446516	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.8 s	20/20	10.0 KiB
446515	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.3 s	20/20	12.5 KiB	10.0 KiB
446514	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.2 s	20/20	8.1 KiB	2.9 KiB
446513	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.1 s	20/20	13.5 KiB	9.6 KiB
446512	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.2 s	1/1		13.5 KiB
446511	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10 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:55:46	0.2 s	1/1		8.1 KiB

Page: