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

Status: SUCCEEDED
Submitted: 2026/08/10 08:17:46
Duration: 2 s
Associated SQL Query: 85
Job Group: f6fc2d63-a255-4383-a46a-6581aeff922a
Completed Stages: 6

Enable zooming

digraph G { id="graph_646"; subgraph graph_stage_646 { id="graph_stage_646"; isCluster="true"; label="Stage 646"; subgraph cluster_2720 { id="cluster_2720"; isCluster="true"; label="Scan parquet "; 1063 [id="node_1063" labelType="html" label="FileScanRDD [1063] start at FileStorageAdapterImpl.java:177}"]; 1064 [id="node_1064" labelType="html" label="MapPartitionsRDD [1064] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2716 { id="cluster_2716"; isCluster="true"; label="WholeStageCodegen (1)"; 1065 [id="node_1065" labelType="html" label="MapPartitionsRDD [1065] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2715 { id="cluster_2715"; isCluster="true"; label="Exchange"; 1066 [id="node_1066" labelType="html" label="MapPartitionsRDD [1066] start at FileStorageAdapterImpl.java:177}"]; } } 1063->1064; 1064->1065; 1065->1066; }

digraph G { id="graph_647"; subgraph graph_stage_647 { id="graph_stage_647"; isCluster="true"; label="Stage 647"; subgraph cluster_2746 { id="cluster_2746"; isCluster="true"; label="Scan parquet "; 1074 [id="node_1074" labelType="html" label="FileScanRDD [1074] start at FileStorageAdapterImpl.java:177}"]; 1075 [id="node_1075" labelType="html" label="MapPartitionsRDD [1075] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2742 { id="cluster_2742"; isCluster="true"; label="WholeStageCodegen (7)"; 1076 [id="node_1076" labelType="html" label="MapPartitionsRDD [1076] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2741 { id="cluster_2741"; isCluster="true"; label="Exchange"; 1077 [id="node_1077" labelType="html" label="MapPartitionsRDD [1077] start at FileStorageAdapterImpl.java:177}"]; } } 1074->1075; 1075->1076; 1076->1077; }

digraph G { id="graph_648"; subgraph graph_stage_648 { id="graph_stage_648"; isCluster="true"; label="Stage 648"; subgraph cluster_2741 { id="cluster_2741"; isCluster="true"; label="Exchange"; 1078 [id="node_1078" labelType="html" label="ShuffledRowRDD [1078] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2726 { id="cluster_2726"; isCluster="true"; label="WholeStageCodegen (11)"; 1079 [id="node_1079" labelType="html" label="MapPartitionsRDD [1079] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2725 { id="cluster_2725"; isCluster="true"; label="Exchange"; 1080 [id="node_1080" labelType="html" label="MapPartitionsRDD [1080] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1078->1079; 1079->1080; }

1077,1078

digraph G { id="graph_649"; subgraph graph_stage_649 { id="graph_stage_649"; isCluster="true"; label="Stage 649"; subgraph cluster_2715 { id="cluster_2715"; isCluster="true"; label="Exchange"; 1067 [id="node_1067" labelType="html" label="ShuffledRowRDD [1067] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2687 { id="cluster_2687"; isCluster="true"; label="WholeStageCodegen (5)"; 1068 [id="node_1068" labelType="html" label="MapPartitionsRDD [1068] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2686 { id="cluster_2686"; isCluster="true"; label="Exchange"; 1069 [id="node_1069" labelType="html" label="MapPartitionsRDD [1069] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1067->1068; 1068->1069; }

1066,1067

digraph G { id="graph_650"; subgraph graph_stage_650 { id="graph_stage_650"; isCluster="true"; label="Stage 650"; subgraph cluster_2686 { id="cluster_2686"; isCluster="true"; label="Exchange"; 1070 [id="node_1070" labelType="html" label="ShuffledRowRDD [1070] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2683 { id="cluster_2683"; isCluster="true"; label="WholeStageCodegen (6)"; 1071 [id="node_1071" labelType="html" label="MapPartitionsRDD [1071] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2725 { id="cluster_2725"; isCluster="true"; label="Exchange"; 1081 [id="node_1081" labelType="html" label="ShuffledRowRDD [1081] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2722 { id="cluster_2722"; isCluster="true"; label="WholeStageCodegen (12)"; 1082 [id="node_1082" labelType="html" label="MapPartitionsRDD [1082] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2679 { id="cluster_2679"; isCluster="true"; label="WholeStageCodegen (13)"; 1083 [id="node_1083" labelType="html" label="ZippedPartitionsRDD2 [1083] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1084 [id="node_1084" labelType="html" label="MapPartitionsRDD [1084] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2678 { id="cluster_2678"; isCluster="true"; label="ObjectHashAggregate"; 1085 [id="node_1085" labelType="html" label="MapPartitionsRDD [1085] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2677 { id="cluster_2677"; isCluster="true"; label="Exchange"; 1086 [id="node_1086" labelType="html" label="MapPartitionsRDD [1086] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1070->1071; 1081->1082; 1071->1083; 1082->1083; 1083->1084; 1084->1085; 1085->1086; }

1069,1070

1080,1081

digraph G { id="graph_651"; subgraph graph_stage_651 { id="graph_stage_651"; isCluster="true"; label="Stage 651"; 1095 [id="node_1095" labelType="html" label="SQLExecutionRDD [1095] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_2677 { id="cluster_2677"; isCluster="true"; label="Exchange"; 1087 [id="node_1087" labelType="html" label="ShuffledRowRDD [1087] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2676 { id="cluster_2676"; isCluster="true"; label="ObjectHashAggregate"; 1088 [id="node_1088" labelType="html" label="MapPartitionsRDD [1088] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2675 { id="cluster_2675"; isCluster="true"; label="Project"; 1089 [id="node_1089" labelType="html" label="MapPartitionsRDD [1089] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2662 { id="cluster_2662"; isCluster="true"; label="WholeStageCodegen (16)"; 1090 [id="node_1090" labelType="html" label="MapPartitionsRDD [1090] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2661 { id="cluster_2661"; isCluster="true"; label="DeserializeToObject"; 1091 [id="node_1091" labelType="html" label="MapPartitionsRDD [1091] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2643 { id="cluster_2643"; isCluster="true"; label="MapPartitions"; 1092 [id="node_1092" labelType="html" label="MapPartitionsRDD [1092] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2598 { id="cluster_2598"; isCluster="true"; label="WholeStageCodegen (19)"; 1093 [id="node_1093" labelType="html" label="MapPartitionsRDD [1093] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2577 { id="cluster_2577"; isCluster="true"; label="DeserializeToObject"; 1094 [id="node_1094" labelType="html" label="MapPartitionsRDD [1094] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2754 { id="cluster_2754"; isCluster="true"; label="mapPartitions"; 1096 [id="node_1096" labelType="html" label="MapPartitionsRDD [1096] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2755 { id="cluster_2755"; isCluster="true"; label="mapPartitions"; 1097 [id="node_1097" labelType="html" label="MapPartitionsRDD [1097] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1087->1088; 1088->1089; 1089->1090; 1090->1091; 1091->1092; 1092->1093; 1093->1094; 1094->1095; 1095->1096; 1096->1097; }

1086,1087

1097

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
651	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:47	2 s	20/20	162.1 KiB
650	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:46	0.4 s	20/20	212.6 KiB	162.1 KiB
649	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:46	0.1 s	20/20	79.4 KiB	161.8 KiB
648	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:46	0.1 s	20/20	43.6 KiB	50.7 KiB
647	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:46	0.1 s	1/1		43.6 KiB
646	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 4 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:17:46	0.2 s	1/1		79.4 KiB

Page: