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

Status: SUCCEEDED
Submitted: 2026/07/22 18:07:30
Duration: 2 s
Associated SQL Query: 16119
Job Group: 185bab19-86a5-4b48-bb51-7bd63638d291
Completed Stages: 6

Enable zooming

digraph G { id="graph_69454"; subgraph graph_stage_69454 { id="graph_stage_69454"; isCluster="true"; label="Stage 69454"; subgraph cluster_515756 { id="cluster_515756"; isCluster="true"; label="Scan parquet "; 195763 [id="node_195763" labelType="html" label="FileScanRDD [195763] start at FileStorageAdapterImpl.java:179}"]; 195764 [id="node_195764" labelType="html" label="MapPartitionsRDD [195764] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515752 { id="cluster_515752"; isCluster="true"; label="WholeStageCodegen (1)"; 195765 [id="node_195765" labelType="html" label="MapPartitionsRDD [195765] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515751 { id="cluster_515751"; isCluster="true"; label="Exchange"; 195766 [id="node_195766" labelType="html" label="MapPartitionsRDD [195766] start at FileStorageAdapterImpl.java:179}"]; } } 195763->195764; 195764->195765; 195765->195766; }

digraph G { id="graph_69455"; subgraph graph_stage_69455 { id="graph_stage_69455"; isCluster="true"; label="Stage 69455"; subgraph cluster_515789 { id="cluster_515789"; isCluster="true"; label="Scan parquet "; 195774 [id="node_195774" labelType="html" label="FileScanRDD [195774] start at FileStorageAdapterImpl.java:179}"]; 195775 [id="node_195775" labelType="html" label="MapPartitionsRDD [195775] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515785 { id="cluster_515785"; isCluster="true"; label="WholeStageCodegen (7)"; 195776 [id="node_195776" labelType="html" label="MapPartitionsRDD [195776] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515784 { id="cluster_515784"; isCluster="true"; label="Exchange"; 195777 [id="node_195777" labelType="html" label="MapPartitionsRDD [195777] start at FileStorageAdapterImpl.java:179}"]; } } 195774->195775; 195775->195776; 195776->195777; }

digraph G { id="graph_69456"; subgraph graph_stage_69456 { id="graph_stage_69456"; isCluster="true"; label="Stage 69456"; subgraph cluster_515784 { id="cluster_515784"; isCluster="true"; label="Exchange"; 195778 [id="node_195778" labelType="html" label="ShuffledRowRDD [195778] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515762 { id="cluster_515762"; isCluster="true"; label="WholeStageCodegen (11)"; 195779 [id="node_195779" labelType="html" label="MapPartitionsRDD [195779] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515761 { id="cluster_515761"; isCluster="true"; label="Exchange"; 195780 [id="node_195780" labelType="html" label="MapPartitionsRDD [195780] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195778->195779; 195779->195780; }

195777,195778

digraph G { id="graph_69457"; subgraph graph_stage_69457 { id="graph_stage_69457"; isCluster="true"; label="Stage 69457"; subgraph cluster_515751 { id="cluster_515751"; isCluster="true"; label="Exchange"; 195767 [id="node_195767" labelType="html" label="ShuffledRowRDD [195767] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515730 { id="cluster_515730"; isCluster="true"; label="WholeStageCodegen (5)"; 195768 [id="node_195768" labelType="html" label="MapPartitionsRDD [195768] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515729 { id="cluster_515729"; isCluster="true"; label="Exchange"; 195769 [id="node_195769" labelType="html" label="MapPartitionsRDD [195769] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195767->195768; 195768->195769; }

195766,195767

digraph G { id="graph_69458"; subgraph graph_stage_69458 { id="graph_stage_69458"; isCluster="true"; label="Stage 69458"; subgraph cluster_515729 { id="cluster_515729"; isCluster="true"; label="Exchange"; 195770 [id="node_195770" labelType="html" label="ShuffledRowRDD [195770] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515726 { id="cluster_515726"; isCluster="true"; label="WholeStageCodegen (6)"; 195771 [id="node_195771" labelType="html" label="MapPartitionsRDD [195771] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515761 { id="cluster_515761"; isCluster="true"; label="Exchange"; 195781 [id="node_195781" labelType="html" label="ShuffledRowRDD [195781] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515758 { id="cluster_515758"; isCluster="true"; label="WholeStageCodegen (12)"; 195782 [id="node_195782" labelType="html" label="MapPartitionsRDD [195782] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515722 { id="cluster_515722"; isCluster="true"; label="WholeStageCodegen (13)"; 195783 [id="node_195783" labelType="html" label="ZippedPartitionsRDD2 [195783] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 195784 [id="node_195784" labelType="html" label="MapPartitionsRDD [195784] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515721 { id="cluster_515721"; isCluster="true"; label="ObjectHashAggregate"; 195785 [id="node_195785" labelType="html" label="MapPartitionsRDD [195785] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515720 { id="cluster_515720"; isCluster="true"; label="Exchange"; 195786 [id="node_195786" labelType="html" label="MapPartitionsRDD [195786] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195770->195771; 195781->195782; 195771->195783; 195782->195783; 195783->195784; 195784->195785; 195785->195786; }

195769,195770

195780,195781

digraph G { id="graph_69459"; subgraph graph_stage_69459 { id="graph_stage_69459"; isCluster="true"; label="Stage 69459"; 195795 [id="node_195795" labelType="html" label="SQLExecutionRDD [195795] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_515720 { id="cluster_515720"; isCluster="true"; label="Exchange"; 195787 [id="node_195787" labelType="html" label="ShuffledRowRDD [195787] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515719 { id="cluster_515719"; isCluster="true"; label="ObjectHashAggregate"; 195788 [id="node_195788" labelType="html" label="MapPartitionsRDD [195788] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515718 { id="cluster_515718"; isCluster="true"; label="Project"; 195789 [id="node_195789" labelType="html" label="MapPartitionsRDD [195789] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515711 { id="cluster_515711"; isCluster="true"; label="WholeStageCodegen (16)"; 195790 [id="node_195790" labelType="html" label="MapPartitionsRDD [195790] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515710 { id="cluster_515710"; isCluster="true"; label="DeserializeToObject"; 195791 [id="node_195791" labelType="html" label="MapPartitionsRDD [195791] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515709 { id="cluster_515709"; isCluster="true"; label="MapPartitions"; 195792 [id="node_195792" labelType="html" label="MapPartitionsRDD [195792] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515641 { id="cluster_515641"; isCluster="true"; label="WholeStageCodegen (19)"; 195793 [id="node_195793" labelType="html" label="MapPartitionsRDD [195793] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515620 { id="cluster_515620"; isCluster="true"; label="DeserializeToObject"; 195794 [id="node_195794" labelType="html" label="MapPartitionsRDD [195794] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515797 { id="cluster_515797"; isCluster="true"; label="mapPartitions"; 195796 [id="node_195796" labelType="html" label="MapPartitionsRDD [195796] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515798 { id="cluster_515798"; isCluster="true"; label="mapPartitions"; 195797 [id="node_195797" labelType="html" label="MapPartitionsRDD [195797] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195787->195788; 195788->195789; 195789->195790; 195790->195791; 195791->195792; 195792->195793; 195793->195794; 195794->195795; 195795->195796; 195796->195797; }

195786,195787

195797

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
69459	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:31	1 s	30/30	366.3 KiB
69458	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:31	0.4 s	30/30	483.0 KiB	366.3 KiB
69457	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:31	0.2 s	30/30	234.9 KiB	369.0 KiB
69456	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:31	0.2 s	30/30	127.6 KiB	114.1 KiB
69455	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:30	0.4 s	37/37		127.6 KiB
69454	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 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/22 18:07:30	0.4 s	37/37		234.9 KiB

Page: