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

Status: SUCCEEDED
Submitted: 2026/05/22 09:49:26
Duration: 3 s
Associated SQL Query: 72926
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 6

Enable zooming

digraph G { id="graph_318688"; subgraph graph_stage_318688 { id="graph_stage_318688"; isCluster="true"; label="Stage 318688"; subgraph cluster_2311275 { id="cluster_2311275"; isCluster="true"; label="Scan parquet "; 891747 [id="node_891747" labelType="html" label="FileScanRDD [891747] start at FileStorageAdapterImpl.java:174}"]; 891748 [id="node_891748" labelType="html" label="MapPartitionsRDD [891748] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311271 { id="cluster_2311271"; isCluster="true"; label="WholeStageCodegen (7)"; 891749 [id="node_891749" labelType="html" label="MapPartitionsRDD [891749] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311270 { id="cluster_2311270"; isCluster="true"; label="Exchange"; 891750 [id="node_891750" labelType="html" label="MapPartitionsRDD [891750] start at FileStorageAdapterImpl.java:174}"]; } } 891747->891748; 891748->891749; 891749->891750; }

digraph G { id="graph_318689"; subgraph graph_stage_318689 { id="graph_stage_318689"; isCluster="true"; label="Stage 318689"; subgraph cluster_2311249 { id="cluster_2311249"; isCluster="true"; label="Scan parquet "; 891736 [id="node_891736" labelType="html" label="FileScanRDD [891736] start at FileStorageAdapterImpl.java:174}"]; 891737 [id="node_891737" labelType="html" label="MapPartitionsRDD [891737] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311245 { id="cluster_2311245"; isCluster="true"; label="WholeStageCodegen (1)"; 891738 [id="node_891738" labelType="html" label="MapPartitionsRDD [891738] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311244 { id="cluster_2311244"; isCluster="true"; label="Exchange"; 891739 [id="node_891739" labelType="html" label="MapPartitionsRDD [891739] start at FileStorageAdapterImpl.java:174}"]; } } 891736->891737; 891737->891738; 891738->891739; }

digraph G { id="graph_318690"; subgraph graph_stage_318690 { id="graph_stage_318690"; isCluster="true"; label="Stage 318690"; subgraph cluster_2311244 { id="cluster_2311244"; isCluster="true"; label="Exchange"; 891740 [id="node_891740" labelType="html" label="ShuffledRowRDD [891740] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311232 { id="cluster_2311232"; isCluster="true"; label="WholeStageCodegen (5)"; 891741 [id="node_891741" labelType="html" label="MapPartitionsRDD [891741] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311231 { id="cluster_2311231"; isCluster="true"; label="Exchange"; 891742 [id="node_891742" labelType="html" label="MapPartitionsRDD [891742] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891740->891741; 891741->891742; }

891739,891740

digraph G { id="graph_318691"; subgraph graph_stage_318691 { id="graph_stage_318691"; isCluster="true"; label="Stage 318691"; subgraph cluster_2311270 { id="cluster_2311270"; isCluster="true"; label="Exchange"; 891751 [id="node_891751" labelType="html" label="ShuffledRowRDD [891751] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311255 { id="cluster_2311255"; isCluster="true"; label="WholeStageCodegen (11)"; 891752 [id="node_891752" labelType="html" label="MapPartitionsRDD [891752] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311254 { id="cluster_2311254"; isCluster="true"; label="Exchange"; 891753 [id="node_891753" labelType="html" label="MapPartitionsRDD [891753] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891751->891752; 891752->891753; }

891750,891751

digraph G { id="graph_318692"; subgraph graph_stage_318692 { id="graph_stage_318692"; isCluster="true"; label="Stage 318692"; subgraph cluster_2311231 { id="cluster_2311231"; isCluster="true"; label="Exchange"; 891743 [id="node_891743" labelType="html" label="ShuffledRowRDD [891743] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311228 { id="cluster_2311228"; isCluster="true"; label="WholeStageCodegen (6)"; 891744 [id="node_891744" labelType="html" label="MapPartitionsRDD [891744] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311254 { id="cluster_2311254"; isCluster="true"; label="Exchange"; 891754 [id="node_891754" labelType="html" label="ShuffledRowRDD [891754] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311251 { id="cluster_2311251"; isCluster="true"; label="WholeStageCodegen (12)"; 891755 [id="node_891755" labelType="html" label="MapPartitionsRDD [891755] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311224 { id="cluster_2311224"; isCluster="true"; label="WholeStageCodegen (13)"; 891756 [id="node_891756" labelType="html" label="ZippedPartitionsRDD2 [891756] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 891757 [id="node_891757" labelType="html" label="MapPartitionsRDD [891757] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311223 { id="cluster_2311223"; isCluster="true"; label="ObjectHashAggregate"; 891758 [id="node_891758" labelType="html" label="MapPartitionsRDD [891758] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311222 { id="cluster_2311222"; isCluster="true"; label="Exchange"; 891759 [id="node_891759" labelType="html" label="MapPartitionsRDD [891759] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891743->891744; 891754->891755; 891744->891756; 891755->891756; 891756->891757; 891757->891758; 891758->891759; }

891742,891743

891753,891754

digraph G { id="graph_318693"; subgraph graph_stage_318693 { id="graph_stage_318693"; isCluster="true"; label="Stage 318693"; 891768 [id="node_891768" labelType="html" label="SQLExecutionRDD [891768] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2311222 { id="cluster_2311222"; isCluster="true"; label="Exchange"; 891760 [id="node_891760" labelType="html" label="ShuffledRowRDD [891760] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311221 { id="cluster_2311221"; isCluster="true"; label="ObjectHashAggregate"; 891761 [id="node_891761" labelType="html" label="MapPartitionsRDD [891761] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311220 { id="cluster_2311220"; isCluster="true"; label="Project"; 891762 [id="node_891762" labelType="html" label="MapPartitionsRDD [891762] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311213 { id="cluster_2311213"; isCluster="true"; label="WholeStageCodegen (16)"; 891763 [id="node_891763" labelType="html" label="MapPartitionsRDD [891763] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311212 { id="cluster_2311212"; isCluster="true"; label="DeserializeToObject"; 891764 [id="node_891764" labelType="html" label="MapPartitionsRDD [891764] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311211 { id="cluster_2311211"; isCluster="true"; label="MapPartitions"; 891765 [id="node_891765" labelType="html" label="MapPartitionsRDD [891765] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311128 { id="cluster_2311128"; isCluster="true"; label="WholeStageCodegen (19)"; 891766 [id="node_891766" labelType="html" label="MapPartitionsRDD [891766] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311106 { id="cluster_2311106"; isCluster="true"; label="DeserializeToObject"; 891767 [id="node_891767" labelType="html" label="MapPartitionsRDD [891767] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311283 { id="cluster_2311283"; isCluster="true"; label="mapPartitions"; 891769 [id="node_891769" labelType="html" label="MapPartitionsRDD [891769] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311284 { id="cluster_2311284"; isCluster="true"; label="mapPartitions"; 891770 [id="node_891770" labelType="html" label="MapPartitionsRDD [891770] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891760->891761; 891761->891762; 891762->891763; 891763->891764; 891764->891765; 891765->891766; 891766->891767; 891767->891768; 891768->891769; 891769->891770; }

891759,891760

891770

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
318693	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:27	1.0 s	30/30	13.2 KiB
318692	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:27	0.9 s	30/30	16.8 KiB	13.2 KiB
318691	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:26	0.4 s	30/30	2.3 KiB	3.1 KiB
318690	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:26	0.2 s	30/30	5.3 KiB	13.7 KiB
318689	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:26	0.4 s	1/1		5.3 KiB
318688	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 30 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.GeneratedMethodAccessor724.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/05/22 09:49:26	0.4 s	1/1		2.3 KiB

Page: