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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:13
Duration: 2 s
Associated SQL Query: 6491
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 6

Enable zooming

digraph G { id="graph_27703"; subgraph graph_stage_27703 { id="graph_stage_27703"; isCluster="true"; label="Stage 27703"; subgraph cluster_205246 { id="cluster_205246"; isCluster="true"; label="Scan parquet "; 77831 [id="node_77831" labelType="html" label="FileScanRDD [77831] start at FileStorageAdapterImpl.java:179}"]; 77832 [id="node_77832" labelType="html" label="MapPartitionsRDD [77832] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205242 { id="cluster_205242"; isCluster="true"; label="WholeStageCodegen (7)"; 77833 [id="node_77833" labelType="html" label="MapPartitionsRDD [77833] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205241 { id="cluster_205241"; isCluster="true"; label="Exchange"; 77834 [id="node_77834" labelType="html" label="MapPartitionsRDD [77834] start at FileStorageAdapterImpl.java:179}"]; } } 77831->77832; 77832->77833; 77833->77834; }

digraph G { id="graph_27704"; subgraph graph_stage_27704 { id="graph_stage_27704"; isCluster="true"; label="Stage 27704"; subgraph cluster_205213 { id="cluster_205213"; isCluster="true"; label="Scan parquet "; 77820 [id="node_77820" labelType="html" label="FileScanRDD [77820] start at FileStorageAdapterImpl.java:179}"]; 77821 [id="node_77821" labelType="html" label="MapPartitionsRDD [77821] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205209 { id="cluster_205209"; isCluster="true"; label="WholeStageCodegen (1)"; 77822 [id="node_77822" labelType="html" label="MapPartitionsRDD [77822] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205208 { id="cluster_205208"; isCluster="true"; label="Exchange"; 77823 [id="node_77823" labelType="html" label="MapPartitionsRDD [77823] start at FileStorageAdapterImpl.java:179}"]; } } 77820->77821; 77821->77822; 77822->77823; }

digraph G { id="graph_27705"; subgraph graph_stage_27705 { id="graph_stage_27705"; isCluster="true"; label="Stage 27705"; subgraph cluster_205208 { id="cluster_205208"; isCluster="true"; label="Exchange"; 77824 [id="node_77824" labelType="html" label="ShuffledRowRDD [77824] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205187 { id="cluster_205187"; isCluster="true"; label="WholeStageCodegen (5)"; 77825 [id="node_77825" labelType="html" label="MapPartitionsRDD [77825] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205186 { id="cluster_205186"; isCluster="true"; label="Exchange"; 77826 [id="node_77826" labelType="html" label="MapPartitionsRDD [77826] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77824->77825; 77825->77826; }

77823,77824

digraph G { id="graph_27706"; subgraph graph_stage_27706 { id="graph_stage_27706"; isCluster="true"; label="Stage 27706"; subgraph cluster_205241 { id="cluster_205241"; isCluster="true"; label="Exchange"; 77835 [id="node_77835" labelType="html" label="ShuffledRowRDD [77835] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205219 { id="cluster_205219"; isCluster="true"; label="WholeStageCodegen (11)"; 77836 [id="node_77836" labelType="html" label="MapPartitionsRDD [77836] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205218 { id="cluster_205218"; isCluster="true"; label="Exchange"; 77837 [id="node_77837" labelType="html" label="MapPartitionsRDD [77837] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77835->77836; 77836->77837; }

77834,77835

digraph G { id="graph_27707"; subgraph graph_stage_27707 { id="graph_stage_27707"; isCluster="true"; label="Stage 27707"; subgraph cluster_205186 { id="cluster_205186"; isCluster="true"; label="Exchange"; 77827 [id="node_77827" labelType="html" label="ShuffledRowRDD [77827] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205183 { id="cluster_205183"; isCluster="true"; label="WholeStageCodegen (6)"; 77828 [id="node_77828" labelType="html" label="MapPartitionsRDD [77828] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205218 { id="cluster_205218"; isCluster="true"; label="Exchange"; 77838 [id="node_77838" labelType="html" label="ShuffledRowRDD [77838] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205215 { id="cluster_205215"; isCluster="true"; label="WholeStageCodegen (12)"; 77839 [id="node_77839" labelType="html" label="MapPartitionsRDD [77839] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205179 { id="cluster_205179"; isCluster="true"; label="WholeStageCodegen (13)"; 77840 [id="node_77840" labelType="html" label="ZippedPartitionsRDD2 [77840] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 77841 [id="node_77841" labelType="html" label="MapPartitionsRDD [77841] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205178 { id="cluster_205178"; isCluster="true"; label="ObjectHashAggregate"; 77842 [id="node_77842" labelType="html" label="MapPartitionsRDD [77842] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205177 { id="cluster_205177"; isCluster="true"; label="Exchange"; 77843 [id="node_77843" labelType="html" label="MapPartitionsRDD [77843] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77827->77828; 77838->77839; 77828->77840; 77839->77840; 77840->77841; 77841->77842; 77842->77843; }

77826,77827

77837,77838

digraph G { id="graph_27708"; subgraph graph_stage_27708 { id="graph_stage_27708"; isCluster="true"; label="Stage 27708"; 77852 [id="node_77852" labelType="html" label="SQLExecutionRDD [77852] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_205177 { id="cluster_205177"; isCluster="true"; label="Exchange"; 77844 [id="node_77844" labelType="html" label="ShuffledRowRDD [77844] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205176 { id="cluster_205176"; isCluster="true"; label="ObjectHashAggregate"; 77845 [id="node_77845" labelType="html" label="MapPartitionsRDD [77845] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205175 { id="cluster_205175"; isCluster="true"; label="Project"; 77846 [id="node_77846" labelType="html" label="MapPartitionsRDD [77846] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205168 { id="cluster_205168"; isCluster="true"; label="WholeStageCodegen (16)"; 77847 [id="node_77847" labelType="html" label="MapPartitionsRDD [77847] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205167 { id="cluster_205167"; isCluster="true"; label="DeserializeToObject"; 77848 [id="node_77848" labelType="html" label="MapPartitionsRDD [77848] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205166 { id="cluster_205166"; isCluster="true"; label="MapPartitions"; 77849 [id="node_77849" labelType="html" label="MapPartitionsRDD [77849] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205099 { id="cluster_205099"; isCluster="true"; label="WholeStageCodegen (19)"; 77850 [id="node_77850" labelType="html" label="MapPartitionsRDD [77850] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205077 { id="cluster_205077"; isCluster="true"; label="DeserializeToObject"; 77851 [id="node_77851" labelType="html" label="MapPartitionsRDD [77851] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205254 { id="cluster_205254"; isCluster="true"; label="mapPartitions"; 77853 [id="node_77853" labelType="html" label="MapPartitionsRDD [77853] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205255 { id="cluster_205255"; isCluster="true"; label="mapPartitions"; 77854 [id="node_77854" labelType="html" label="MapPartitionsRDD [77854] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77844->77845; 77845->77846; 77846->77847; 77847->77848; 77848->77849; 77849->77850; 77850->77851; 77851->77852; 77852->77853; 77853->77854; }

77843,77844

77854

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
27708	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:14	1 s	30/30	371.9 KiB
27707	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:13	0.4 s	30/30	479.2 KiB	371.9 KiB
27706	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:13	0.2 s	30/30	127.6 KiB	113.3 KiB
27705	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:13	0.1 s	30/30	234.9 KiB	365.9 KiB
27704	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:13	0.5 s	37/37		234.9 KiB
27703	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 9 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:13	0.4 s	37/37		127.6 KiB

Page: