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

Status: SUCCEEDED
Submitted: 2026/08/10 09:31:27
Duration: 2 s
Associated SQL Query: 650
Job Group: cd2b79e8-7be4-4311-b6ba-b3d3f3439555
Completed Stages: 6

Enable zooming

digraph G { id="graph_3101"; subgraph graph_stage_3101 { id="graph_stage_3101"; isCluster="true"; label="Stage 3101"; subgraph cluster_21124 { id="cluster_21124"; isCluster="true"; label="Scan parquet "; 7922 [id="node_7922" labelType="html" label="FileScanRDD [7922] start at FileStorageAdapterImpl.java:177}"]; 7923 [id="node_7923" labelType="html" label="MapPartitionsRDD [7923] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21120 { id="cluster_21120"; isCluster="true"; label="WholeStageCodegen (7)"; 7924 [id="node_7924" labelType="html" label="MapPartitionsRDD [7924] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21119 { id="cluster_21119"; isCluster="true"; label="Exchange"; 7925 [id="node_7925" labelType="html" label="MapPartitionsRDD [7925] start at FileStorageAdapterImpl.java:177}"]; } } 7922->7923; 7923->7924; 7924->7925; }

digraph G { id="graph_3102"; subgraph graph_stage_3102 { id="graph_stage_3102"; isCluster="true"; label="Stage 3102"; subgraph cluster_21091 { id="cluster_21091"; isCluster="true"; label="Scan parquet "; 7911 [id="node_7911" labelType="html" label="FileScanRDD [7911] start at FileStorageAdapterImpl.java:177}"]; 7912 [id="node_7912" labelType="html" label="MapPartitionsRDD [7912] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21087 { id="cluster_21087"; isCluster="true"; label="WholeStageCodegen (1)"; 7913 [id="node_7913" labelType="html" label="MapPartitionsRDD [7913] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21086 { id="cluster_21086"; isCluster="true"; label="Exchange"; 7914 [id="node_7914" labelType="html" label="MapPartitionsRDD [7914] start at FileStorageAdapterImpl.java:177}"]; } } 7911->7912; 7912->7913; 7913->7914; }

digraph G { id="graph_3103"; subgraph graph_stage_3103 { id="graph_stage_3103"; isCluster="true"; label="Stage 3103"; subgraph cluster_21086 { id="cluster_21086"; isCluster="true"; label="Exchange"; 7915 [id="node_7915" labelType="html" label="ShuffledRowRDD [7915] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21065 { id="cluster_21065"; isCluster="true"; label="WholeStageCodegen (5)"; 7916 [id="node_7916" labelType="html" label="MapPartitionsRDD [7916] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21064 { id="cluster_21064"; isCluster="true"; label="Exchange"; 7917 [id="node_7917" labelType="html" label="MapPartitionsRDD [7917] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7915->7916; 7916->7917; }

7914,7915

digraph G { id="graph_3104"; subgraph graph_stage_3104 { id="graph_stage_3104"; isCluster="true"; label="Stage 3104"; subgraph cluster_21119 { id="cluster_21119"; isCluster="true"; label="Exchange"; 7926 [id="node_7926" labelType="html" label="ShuffledRowRDD [7926] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21097 { id="cluster_21097"; isCluster="true"; label="WholeStageCodegen (11)"; 7927 [id="node_7927" labelType="html" label="MapPartitionsRDD [7927] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21096 { id="cluster_21096"; isCluster="true"; label="Exchange"; 7928 [id="node_7928" labelType="html" label="MapPartitionsRDD [7928] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7926->7927; 7927->7928; }

7925,7926

digraph G { id="graph_3105"; subgraph graph_stage_3105 { id="graph_stage_3105"; isCluster="true"; label="Stage 3105"; subgraph cluster_21064 { id="cluster_21064"; isCluster="true"; label="Exchange"; 7918 [id="node_7918" labelType="html" label="ShuffledRowRDD [7918] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21061 { id="cluster_21061"; isCluster="true"; label="WholeStageCodegen (6)"; 7919 [id="node_7919" labelType="html" label="MapPartitionsRDD [7919] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21096 { id="cluster_21096"; isCluster="true"; label="Exchange"; 7929 [id="node_7929" labelType="html" label="ShuffledRowRDD [7929] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21093 { id="cluster_21093"; isCluster="true"; label="WholeStageCodegen (12)"; 7930 [id="node_7930" labelType="html" label="MapPartitionsRDD [7930] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21057 { id="cluster_21057"; isCluster="true"; label="WholeStageCodegen (13)"; 7931 [id="node_7931" labelType="html" label="ZippedPartitionsRDD2 [7931] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 7932 [id="node_7932" labelType="html" label="MapPartitionsRDD [7932] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21056 { id="cluster_21056"; isCluster="true"; label="ObjectHashAggregate"; 7933 [id="node_7933" labelType="html" label="MapPartitionsRDD [7933] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21055 { id="cluster_21055"; isCluster="true"; label="Exchange"; 7934 [id="node_7934" labelType="html" label="MapPartitionsRDD [7934] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7918->7919; 7929->7930; 7919->7931; 7930->7931; 7931->7932; 7932->7933; 7933->7934; }

7917,7918

7928,7929

digraph G { id="graph_3106"; subgraph graph_stage_3106 { id="graph_stage_3106"; isCluster="true"; label="Stage 3106"; 7943 [id="node_7943" labelType="html" label="SQLExecutionRDD [7943] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_21055 { id="cluster_21055"; isCluster="true"; label="Exchange"; 7935 [id="node_7935" labelType="html" label="ShuffledRowRDD [7935] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21054 { id="cluster_21054"; isCluster="true"; label="ObjectHashAggregate"; 7936 [id="node_7936" labelType="html" label="MapPartitionsRDD [7936] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21053 { id="cluster_21053"; isCluster="true"; label="Project"; 7937 [id="node_7937" labelType="html" label="MapPartitionsRDD [7937] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21046 { id="cluster_21046"; isCluster="true"; label="WholeStageCodegen (16)"; 7938 [id="node_7938" labelType="html" label="MapPartitionsRDD [7938] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21045 { id="cluster_21045"; isCluster="true"; label="DeserializeToObject"; 7939 [id="node_7939" labelType="html" label="MapPartitionsRDD [7939] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21041 { id="cluster_21041"; isCluster="true"; label="MapPartitions"; 7940 [id="node_7940" labelType="html" label="MapPartitionsRDD [7940] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20976 { id="cluster_20976"; isCluster="true"; label="WholeStageCodegen (19)"; 7941 [id="node_7941" labelType="html" label="MapPartitionsRDD [7941] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20955 { id="cluster_20955"; isCluster="true"; label="DeserializeToObject"; 7942 [id="node_7942" labelType="html" label="MapPartitionsRDD [7942] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21132 { id="cluster_21132"; isCluster="true"; label="mapPartitions"; 7944 [id="node_7944" labelType="html" label="MapPartitionsRDD [7944] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21133 { id="cluster_21133"; isCluster="true"; label="mapPartitions"; 7945 [id="node_7945" labelType="html" label="MapPartitionsRDD [7945] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7935->7936; 7936->7937; 7937->7938; 7938->7939; 7939->7940; 7940->7941; 7941->7942; 7942->7943; 7943->7944; 7944->7945; }

7934,7935

7945

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3106	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:28	2 s	20/20	210.2 KiB
3105	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:27	0.3 s	20/20	261.9 KiB	210.2 KiB
3104	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:27	0.2 s	20/20	15.6 KiB	62.0 KiB
3103	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:27	0.2 s	20/20	22.9 KiB	199.8 KiB
3102	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:27	0.2 s	1/1		22.9 KiB
3101	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 6 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:31:27	0.2 s	1/1		15.6 KiB

Page: