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

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

Enable zooming

digraph G { id="graph_445976"; subgraph graph_stage_445976 { id="graph_stage_445976"; isCluster="true"; label="Stage 445976"; subgraph cluster_3150024 { id="cluster_3150024"; isCluster="true"; label="Scan parquet "; 1242527 [id="node_1242527" labelType="html" label="FileScanRDD [1242527] start at FileStorageAdapterImpl.java:174}"]; 1242528 [id="node_1242528" labelType="html" label="MapPartitionsRDD [1242528] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150020 { id="cluster_3150020"; isCluster="true"; label="WholeStageCodegen (7)"; 1242529 [id="node_1242529" labelType="html" label="MapPartitionsRDD [1242529] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150019 { id="cluster_3150019"; isCluster="true"; label="Exchange"; 1242530 [id="node_1242530" labelType="html" label="MapPartitionsRDD [1242530] start at FileStorageAdapterImpl.java:174}"]; } } 1242527->1242528; 1242528->1242529; 1242529->1242530; }

digraph G { id="graph_445977"; subgraph graph_stage_445977 { id="graph_stage_445977"; isCluster="true"; label="Stage 445977"; subgraph cluster_3149998 { id="cluster_3149998"; isCluster="true"; label="Scan parquet "; 1242516 [id="node_1242516" labelType="html" label="FileScanRDD [1242516] start at FileStorageAdapterImpl.java:174}"]; 1242517 [id="node_1242517" labelType="html" label="MapPartitionsRDD [1242517] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149994 { id="cluster_3149994"; isCluster="true"; label="WholeStageCodegen (1)"; 1242518 [id="node_1242518" labelType="html" label="MapPartitionsRDD [1242518] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149993 { id="cluster_3149993"; isCluster="true"; label="Exchange"; 1242519 [id="node_1242519" labelType="html" label="MapPartitionsRDD [1242519] start at FileStorageAdapterImpl.java:174}"]; } } 1242516->1242517; 1242517->1242518; 1242518->1242519; }

digraph G { id="graph_445978"; subgraph graph_stage_445978 { id="graph_stage_445978"; isCluster="true"; label="Stage 445978"; subgraph cluster_3149993 { id="cluster_3149993"; isCluster="true"; label="Exchange"; 1242520 [id="node_1242520" labelType="html" label="ShuffledRowRDD [1242520] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149965 { id="cluster_3149965"; isCluster="true"; label="WholeStageCodegen (5)"; 1242521 [id="node_1242521" labelType="html" label="MapPartitionsRDD [1242521] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149964 { id="cluster_3149964"; isCluster="true"; label="Exchange"; 1242522 [id="node_1242522" labelType="html" label="MapPartitionsRDD [1242522] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242520->1242521; 1242521->1242522; }

1242519,1242520

digraph G { id="graph_445979"; subgraph graph_stage_445979 { id="graph_stage_445979"; isCluster="true"; label="Stage 445979"; subgraph cluster_3150019 { id="cluster_3150019"; isCluster="true"; label="Exchange"; 1242531 [id="node_1242531" labelType="html" label="ShuffledRowRDD [1242531] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150004 { id="cluster_3150004"; isCluster="true"; label="WholeStageCodegen (11)"; 1242532 [id="node_1242532" labelType="html" label="MapPartitionsRDD [1242532] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150003 { id="cluster_3150003"; isCluster="true"; label="Exchange"; 1242533 [id="node_1242533" labelType="html" label="MapPartitionsRDD [1242533] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242531->1242532; 1242532->1242533; }

1242530,1242531

digraph G { id="graph_445980"; subgraph graph_stage_445980 { id="graph_stage_445980"; isCluster="true"; label="Stage 445980"; subgraph cluster_3149964 { id="cluster_3149964"; isCluster="true"; label="Exchange"; 1242523 [id="node_1242523" labelType="html" label="ShuffledRowRDD [1242523] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149961 { id="cluster_3149961"; isCluster="true"; label="WholeStageCodegen (6)"; 1242524 [id="node_1242524" labelType="html" label="MapPartitionsRDD [1242524] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150003 { id="cluster_3150003"; isCluster="true"; label="Exchange"; 1242534 [id="node_1242534" labelType="html" label="ShuffledRowRDD [1242534] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150000 { id="cluster_3150000"; isCluster="true"; label="WholeStageCodegen (12)"; 1242535 [id="node_1242535" labelType="html" label="MapPartitionsRDD [1242535] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149957 { id="cluster_3149957"; isCluster="true"; label="WholeStageCodegen (13)"; 1242536 [id="node_1242536" labelType="html" label="ZippedPartitionsRDD2 [1242536] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242537 [id="node_1242537" labelType="html" label="MapPartitionsRDD [1242537] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149956 { id="cluster_3149956"; isCluster="true"; label="ObjectHashAggregate"; 1242538 [id="node_1242538" labelType="html" label="MapPartitionsRDD [1242538] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149955 { id="cluster_3149955"; isCluster="true"; label="Exchange"; 1242539 [id="node_1242539" labelType="html" label="MapPartitionsRDD [1242539] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242523->1242524; 1242534->1242535; 1242524->1242536; 1242535->1242536; 1242536->1242537; 1242537->1242538; 1242538->1242539; }

1242522,1242523

1242533,1242534

digraph G { id="graph_445981"; subgraph graph_stage_445981 { id="graph_stage_445981"; isCluster="true"; label="Stage 445981"; 1242548 [id="node_1242548" labelType="html" label="SQLExecutionRDD [1242548] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3149955 { id="cluster_3149955"; isCluster="true"; label="Exchange"; 1242540 [id="node_1242540" labelType="html" label="ShuffledRowRDD [1242540] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149954 { id="cluster_3149954"; isCluster="true"; label="ObjectHashAggregate"; 1242541 [id="node_1242541" labelType="html" label="MapPartitionsRDD [1242541] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149953 { id="cluster_3149953"; isCluster="true"; label="Project"; 1242542 [id="node_1242542" labelType="html" label="MapPartitionsRDD [1242542] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149946 { id="cluster_3149946"; isCluster="true"; label="WholeStageCodegen (16)"; 1242543 [id="node_1242543" labelType="html" label="MapPartitionsRDD [1242543] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149945 { id="cluster_3149945"; isCluster="true"; label="DeserializeToObject"; 1242544 [id="node_1242544" labelType="html" label="MapPartitionsRDD [1242544] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149944 { id="cluster_3149944"; isCluster="true"; label="MapPartitions"; 1242545 [id="node_1242545" labelType="html" label="MapPartitionsRDD [1242545] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149876 { id="cluster_3149876"; isCluster="true"; label="WholeStageCodegen (19)"; 1242546 [id="node_1242546" labelType="html" label="MapPartitionsRDD [1242546] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149855 { id="cluster_3149855"; isCluster="true"; label="DeserializeToObject"; 1242547 [id="node_1242547" labelType="html" label="MapPartitionsRDD [1242547] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150032 { id="cluster_3150032"; isCluster="true"; label="mapPartitions"; 1242549 [id="node_1242549" labelType="html" label="MapPartitionsRDD [1242549] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150033 { id="cluster_3150033"; isCluster="true"; label="mapPartitions"; 1242550 [id="node_1242550" labelType="html" label="MapPartitionsRDD [1242550] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242540->1242541; 1242541->1242542; 1242542->1242543; 1242543->1242544; 1242544->1242545; 1242545->1242546; 1242546->1242547; 1242547->1242548; 1242548->1242549; 1242549->1242550; }

1242539,1242540

1242550

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
445981	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:17	2 s	20/20	68.0 KiB
445980	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:17	0.4 s	20/20	84.6 KiB	68.0 KiB
445979	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:17	0.2 s	20/20	8.1 KiB	21.7 KiB
445978	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:17	0.1 s	20/20	13.5 KiB	62.9 KiB
445977	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:16	0.2 s	1/1		13.5 KiB
445976	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 3 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:51:16	0.2 s	1/1		8.1 KiB

Page: