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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:01
Duration: 3 s
Associated SQL Query: 810
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 6

Enable zooming

digraph G { id="graph_3863"; subgraph graph_stage_3863 { id="graph_stage_3863"; isCluster="true"; label="Stage 3863"; subgraph cluster_26749 { id="cluster_26749"; isCluster="true"; label="Scan parquet "; 9892 [id="node_9892" labelType="html" label="FileScanRDD [9892] start at FileStorageAdapterImpl.java:177}"]; 9893 [id="node_9893" labelType="html" label="MapPartitionsRDD [9893] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26745 { id="cluster_26745"; isCluster="true"; label="WholeStageCodegen (1)"; 9894 [id="node_9894" labelType="html" label="MapPartitionsRDD [9894] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26744 { id="cluster_26744"; isCluster="true"; label="Exchange"; 9895 [id="node_9895" labelType="html" label="MapPartitionsRDD [9895] start at FileStorageAdapterImpl.java:177}"]; } } 9892->9893; 9893->9894; 9894->9895; }

digraph G { id="graph_3864"; subgraph graph_stage_3864 { id="graph_stage_3864"; isCluster="true"; label="Stage 3864"; subgraph cluster_26782 { id="cluster_26782"; isCluster="true"; label="Scan parquet "; 9903 [id="node_9903" labelType="html" label="FileScanRDD [9903] start at FileStorageAdapterImpl.java:177}"]; 9904 [id="node_9904" labelType="html" label="MapPartitionsRDD [9904] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26778 { id="cluster_26778"; isCluster="true"; label="WholeStageCodegen (7)"; 9905 [id="node_9905" labelType="html" label="MapPartitionsRDD [9905] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26777 { id="cluster_26777"; isCluster="true"; label="Exchange"; 9906 [id="node_9906" labelType="html" label="MapPartitionsRDD [9906] start at FileStorageAdapterImpl.java:177}"]; } } 9903->9904; 9904->9905; 9905->9906; }

digraph G { id="graph_3865"; subgraph graph_stage_3865 { id="graph_stage_3865"; isCluster="true"; label="Stage 3865"; subgraph cluster_26777 { id="cluster_26777"; isCluster="true"; label="Exchange"; 9907 [id="node_9907" labelType="html" label="ShuffledRowRDD [9907] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26755 { id="cluster_26755"; isCluster="true"; label="WholeStageCodegen (11)"; 9908 [id="node_9908" labelType="html" label="MapPartitionsRDD [9908] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26754 { id="cluster_26754"; isCluster="true"; label="Exchange"; 9909 [id="node_9909" labelType="html" label="MapPartitionsRDD [9909] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9907->9908; 9908->9909; }

9906,9907

digraph G { id="graph_3866"; subgraph graph_stage_3866 { id="graph_stage_3866"; isCluster="true"; label="Stage 3866"; subgraph cluster_26744 { id="cluster_26744"; isCluster="true"; label="Exchange"; 9896 [id="node_9896" labelType="html" label="ShuffledRowRDD [9896] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26723 { id="cluster_26723"; isCluster="true"; label="WholeStageCodegen (5)"; 9897 [id="node_9897" labelType="html" label="MapPartitionsRDD [9897] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26722 { id="cluster_26722"; isCluster="true"; label="Exchange"; 9898 [id="node_9898" labelType="html" label="MapPartitionsRDD [9898] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9896->9897; 9897->9898; }

9895,9896

digraph G { id="graph_3867"; subgraph graph_stage_3867 { id="graph_stage_3867"; isCluster="true"; label="Stage 3867"; subgraph cluster_26722 { id="cluster_26722"; isCluster="true"; label="Exchange"; 9899 [id="node_9899" labelType="html" label="ShuffledRowRDD [9899] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26719 { id="cluster_26719"; isCluster="true"; label="WholeStageCodegen (6)"; 9900 [id="node_9900" labelType="html" label="MapPartitionsRDD [9900] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26754 { id="cluster_26754"; isCluster="true"; label="Exchange"; 9910 [id="node_9910" labelType="html" label="ShuffledRowRDD [9910] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26751 { id="cluster_26751"; isCluster="true"; label="WholeStageCodegen (12)"; 9911 [id="node_9911" labelType="html" label="MapPartitionsRDD [9911] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26715 { id="cluster_26715"; isCluster="true"; label="WholeStageCodegen (13)"; 9912 [id="node_9912" labelType="html" label="ZippedPartitionsRDD2 [9912] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9913 [id="node_9913" labelType="html" label="MapPartitionsRDD [9913] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26714 { id="cluster_26714"; isCluster="true"; label="ObjectHashAggregate"; 9914 [id="node_9914" labelType="html" label="MapPartitionsRDD [9914] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26713 { id="cluster_26713"; isCluster="true"; label="Exchange"; 9915 [id="node_9915" labelType="html" label="MapPartitionsRDD [9915] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9899->9900; 9910->9911; 9900->9912; 9911->9912; 9912->9913; 9913->9914; 9914->9915; }

9898,9899

9909,9910

digraph G { id="graph_3868"; subgraph graph_stage_3868 { id="graph_stage_3868"; isCluster="true"; label="Stage 3868"; 9924 [id="node_9924" labelType="html" label="SQLExecutionRDD [9924] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_26713 { id="cluster_26713"; isCluster="true"; label="Exchange"; 9916 [id="node_9916" labelType="html" label="ShuffledRowRDD [9916] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26712 { id="cluster_26712"; isCluster="true"; label="ObjectHashAggregate"; 9917 [id="node_9917" labelType="html" label="MapPartitionsRDD [9917] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26711 { id="cluster_26711"; isCluster="true"; label="Project"; 9918 [id="node_9918" labelType="html" label="MapPartitionsRDD [9918] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26704 { id="cluster_26704"; isCluster="true"; label="WholeStageCodegen (16)"; 9919 [id="node_9919" labelType="html" label="MapPartitionsRDD [9919] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26703 { id="cluster_26703"; isCluster="true"; label="DeserializeToObject"; 9920 [id="node_9920" labelType="html" label="MapPartitionsRDD [9920] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26702 { id="cluster_26702"; isCluster="true"; label="MapPartitions"; 9921 [id="node_9921" labelType="html" label="MapPartitionsRDD [9921] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26633 { id="cluster_26633"; isCluster="true"; label="WholeStageCodegen (19)"; 9922 [id="node_9922" labelType="html" label="MapPartitionsRDD [9922] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26613 { id="cluster_26613"; isCluster="true"; label="DeserializeToObject"; 9923 [id="node_9923" labelType="html" label="MapPartitionsRDD [9923] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26790 { id="cluster_26790"; isCluster="true"; label="mapPartitions"; 9925 [id="node_9925" labelType="html" label="MapPartitionsRDD [9925] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26791 { id="cluster_26791"; isCluster="true"; label="mapPartitions"; 9926 [id="node_9926" labelType="html" label="MapPartitionsRDD [9926] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9916->9917; 9917->9918; 9918->9919; 9919->9920; 9920->9921; 9921->9922; 9922->9923; 9923->9924; 9924->9925; 9925->9926; }

9915,9916

9926

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3868	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:02	2 s	20/20	523.6 KiB
3867	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:01	0.4 s	20/20	710.3 KiB	523.6 KiB
3866	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:01	0.1 s	20/20	79.5 KiB	517.5 KiB
3865	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:01	0.2 s	20/20	43.6 KiB	192.8 KiB
3864	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:01	0.2 s	1/1		43.6 KiB
3863	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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 09:41:01	0.2 s	1/1		79.5 KiB

Page: