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

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

Enable zooming

digraph G { id="graph_3179"; subgraph graph_stage_3179 { id="graph_stage_3179"; isCluster="true"; label="Stage 3179"; subgraph cluster_21697 { id="cluster_21697"; isCluster="true"; label="Scan parquet "; 8157 [id="node_8157" labelType="html" label="FileScanRDD [8157] start at FileStorageAdapterImpl.java:177}"]; 8158 [id="node_8158" labelType="html" label="MapPartitionsRDD [8158] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21693 { id="cluster_21693"; isCluster="true"; label="WholeStageCodegen (7)"; 8159 [id="node_8159" labelType="html" label="MapPartitionsRDD [8159] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21692 { id="cluster_21692"; isCluster="true"; label="Exchange"; 8160 [id="node_8160" labelType="html" label="MapPartitionsRDD [8160] start at FileStorageAdapterImpl.java:177}"]; } } 8157->8158; 8158->8159; 8159->8160; }

digraph G { id="graph_3180"; subgraph graph_stage_3180 { id="graph_stage_3180"; isCluster="true"; label="Stage 3180"; subgraph cluster_21664 { id="cluster_21664"; isCluster="true"; label="Scan parquet "; 8146 [id="node_8146" labelType="html" label="FileScanRDD [8146] start at FileStorageAdapterImpl.java:177}"]; 8147 [id="node_8147" labelType="html" label="MapPartitionsRDD [8147] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21660 { id="cluster_21660"; isCluster="true"; label="WholeStageCodegen (1)"; 8148 [id="node_8148" labelType="html" label="MapPartitionsRDD [8148] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21659 { id="cluster_21659"; isCluster="true"; label="Exchange"; 8149 [id="node_8149" labelType="html" label="MapPartitionsRDD [8149] start at FileStorageAdapterImpl.java:177}"]; } } 8146->8147; 8147->8148; 8148->8149; }

digraph G { id="graph_3181"; subgraph graph_stage_3181 { id="graph_stage_3181"; isCluster="true"; label="Stage 3181"; subgraph cluster_21659 { id="cluster_21659"; isCluster="true"; label="Exchange"; 8150 [id="node_8150" labelType="html" label="ShuffledRowRDD [8150] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21638 { id="cluster_21638"; isCluster="true"; label="WholeStageCodegen (5)"; 8151 [id="node_8151" labelType="html" label="MapPartitionsRDD [8151] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21637 { id="cluster_21637"; isCluster="true"; label="Exchange"; 8152 [id="node_8152" labelType="html" label="MapPartitionsRDD [8152] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8150->8151; 8151->8152; }

8149,8150

digraph G { id="graph_3182"; subgraph graph_stage_3182 { id="graph_stage_3182"; isCluster="true"; label="Stage 3182"; subgraph cluster_21692 { id="cluster_21692"; isCluster="true"; label="Exchange"; 8161 [id="node_8161" labelType="html" label="ShuffledRowRDD [8161] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21670 { id="cluster_21670"; isCluster="true"; label="WholeStageCodegen (11)"; 8162 [id="node_8162" labelType="html" label="MapPartitionsRDD [8162] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21669 { id="cluster_21669"; isCluster="true"; label="Exchange"; 8163 [id="node_8163" labelType="html" label="MapPartitionsRDD [8163] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8161->8162; 8162->8163; }

8160,8161

digraph G { id="graph_3183"; subgraph graph_stage_3183 { id="graph_stage_3183"; isCluster="true"; label="Stage 3183"; subgraph cluster_21637 { id="cluster_21637"; isCluster="true"; label="Exchange"; 8153 [id="node_8153" labelType="html" label="ShuffledRowRDD [8153] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21634 { id="cluster_21634"; isCluster="true"; label="WholeStageCodegen (6)"; 8154 [id="node_8154" labelType="html" label="MapPartitionsRDD [8154] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21669 { id="cluster_21669"; isCluster="true"; label="Exchange"; 8164 [id="node_8164" labelType="html" label="ShuffledRowRDD [8164] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21666 { id="cluster_21666"; isCluster="true"; label="WholeStageCodegen (12)"; 8165 [id="node_8165" labelType="html" label="MapPartitionsRDD [8165] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21630 { id="cluster_21630"; isCluster="true"; label="WholeStageCodegen (13)"; 8166 [id="node_8166" labelType="html" label="ZippedPartitionsRDD2 [8166] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8167 [id="node_8167" labelType="html" label="MapPartitionsRDD [8167] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21629 { id="cluster_21629"; isCluster="true"; label="ObjectHashAggregate"; 8168 [id="node_8168" labelType="html" label="MapPartitionsRDD [8168] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21628 { id="cluster_21628"; isCluster="true"; label="Exchange"; 8169 [id="node_8169" labelType="html" label="MapPartitionsRDD [8169] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8153->8154; 8164->8165; 8154->8166; 8165->8166; 8166->8167; 8167->8168; 8168->8169; }

8152,8153

8163,8164

digraph G { id="graph_3184"; subgraph graph_stage_3184 { id="graph_stage_3184"; isCluster="true"; label="Stage 3184"; 8178 [id="node_8178" labelType="html" label="SQLExecutionRDD [8178] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_21628 { id="cluster_21628"; isCluster="true"; label="Exchange"; 8170 [id="node_8170" labelType="html" label="ShuffledRowRDD [8170] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21627 { id="cluster_21627"; isCluster="true"; label="ObjectHashAggregate"; 8171 [id="node_8171" labelType="html" label="MapPartitionsRDD [8171] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21626 { id="cluster_21626"; isCluster="true"; label="Project"; 8172 [id="node_8172" labelType="html" label="MapPartitionsRDD [8172] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21619 { id="cluster_21619"; isCluster="true"; label="WholeStageCodegen (16)"; 8173 [id="node_8173" labelType="html" label="MapPartitionsRDD [8173] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21618 { id="cluster_21618"; isCluster="true"; label="DeserializeToObject"; 8174 [id="node_8174" labelType="html" label="MapPartitionsRDD [8174] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21617 { id="cluster_21617"; isCluster="true"; label="MapPartitions"; 8175 [id="node_8175" labelType="html" label="MapPartitionsRDD [8175] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21549 { id="cluster_21549"; isCluster="true"; label="WholeStageCodegen (19)"; 8176 [id="node_8176" labelType="html" label="MapPartitionsRDD [8176] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21528 { id="cluster_21528"; isCluster="true"; label="DeserializeToObject"; 8177 [id="node_8177" labelType="html" label="MapPartitionsRDD [8177] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21705 { id="cluster_21705"; isCluster="true"; label="mapPartitions"; 8179 [id="node_8179" labelType="html" label="MapPartitionsRDD [8179] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21706 { id="cluster_21706"; isCluster="true"; label="mapPartitions"; 8180 [id="node_8180" labelType="html" label="MapPartitionsRDD [8180] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8170->8171; 8171->8172; 8172->8173; 8173->8174; 8174->8175; 8175->8176; 8176->8177; 8177->8178; 8178->8179; 8179->8180; }

8169,8170

8180

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3184	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:28	2 s	20/20	212.8 KiB
3183	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:27	0.4 s	20/20	269.5 KiB	212.8 KiB
3182	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:27	0.1 s	20/20	15.6 KiB	62.0 KiB
3181	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:27	0.1 s	20/20	22.9 KiB	207.5 KiB
3180	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:27	0.2 s	1/1		22.9 KiB
3179	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7 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:32:27	0.2 s	1/1		15.6 KiB

Page: