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

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

Enable zooming

digraph G { id="graph_69301"; subgraph graph_stage_69301 { id="graph_stage_69301"; isCluster="true"; label="Stage 69301"; subgraph cluster_514692 { id="cluster_514692"; isCluster="true"; label="Scan parquet "; 195325 [id="node_195325" labelType="html" label="FileScanRDD [195325] start at FileStorageAdapterImpl.java:179}"]; 195326 [id="node_195326" labelType="html" label="MapPartitionsRDD [195326] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514688 { id="cluster_514688"; isCluster="true"; label="WholeStageCodegen (7)"; 195327 [id="node_195327" labelType="html" label="MapPartitionsRDD [195327] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514687 { id="cluster_514687"; isCluster="true"; label="Exchange"; 195328 [id="node_195328" labelType="html" label="MapPartitionsRDD [195328] start at FileStorageAdapterImpl.java:179}"]; } } 195325->195326; 195326->195327; 195327->195328; }

digraph G { id="graph_69302"; subgraph graph_stage_69302 { id="graph_stage_69302"; isCluster="true"; label="Stage 69302"; subgraph cluster_514659 { id="cluster_514659"; isCluster="true"; label="Scan parquet "; 195314 [id="node_195314" labelType="html" label="FileScanRDD [195314] start at FileStorageAdapterImpl.java:179}"]; 195315 [id="node_195315" labelType="html" label="MapPartitionsRDD [195315] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514655 { id="cluster_514655"; isCluster="true"; label="WholeStageCodegen (1)"; 195316 [id="node_195316" labelType="html" label="MapPartitionsRDD [195316] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514654 { id="cluster_514654"; isCluster="true"; label="Exchange"; 195317 [id="node_195317" labelType="html" label="MapPartitionsRDD [195317] start at FileStorageAdapterImpl.java:179}"]; } } 195314->195315; 195315->195316; 195316->195317; }

digraph G { id="graph_69303"; subgraph graph_stage_69303 { id="graph_stage_69303"; isCluster="true"; label="Stage 69303"; subgraph cluster_514654 { id="cluster_514654"; isCluster="true"; label="Exchange"; 195318 [id="node_195318" labelType="html" label="ShuffledRowRDD [195318] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514633 { id="cluster_514633"; isCluster="true"; label="WholeStageCodegen (5)"; 195319 [id="node_195319" labelType="html" label="MapPartitionsRDD [195319] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514632 { id="cluster_514632"; isCluster="true"; label="Exchange"; 195320 [id="node_195320" labelType="html" label="MapPartitionsRDD [195320] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195318->195319; 195319->195320; }

195317,195318

digraph G { id="graph_69304"; subgraph graph_stage_69304 { id="graph_stage_69304"; isCluster="true"; label="Stage 69304"; subgraph cluster_514687 { id="cluster_514687"; isCluster="true"; label="Exchange"; 195329 [id="node_195329" labelType="html" label="ShuffledRowRDD [195329] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514665 { id="cluster_514665"; isCluster="true"; label="WholeStageCodegen (11)"; 195330 [id="node_195330" labelType="html" label="MapPartitionsRDD [195330] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514664 { id="cluster_514664"; isCluster="true"; label="Exchange"; 195331 [id="node_195331" labelType="html" label="MapPartitionsRDD [195331] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195329->195330; 195330->195331; }

195328,195329

digraph G { id="graph_69305"; subgraph graph_stage_69305 { id="graph_stage_69305"; isCluster="true"; label="Stage 69305"; subgraph cluster_514632 { id="cluster_514632"; isCluster="true"; label="Exchange"; 195321 [id="node_195321" labelType="html" label="ShuffledRowRDD [195321] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514629 { id="cluster_514629"; isCluster="true"; label="WholeStageCodegen (6)"; 195322 [id="node_195322" labelType="html" label="MapPartitionsRDD [195322] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514664 { id="cluster_514664"; isCluster="true"; label="Exchange"; 195332 [id="node_195332" labelType="html" label="ShuffledRowRDD [195332] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514661 { id="cluster_514661"; isCluster="true"; label="WholeStageCodegen (12)"; 195333 [id="node_195333" labelType="html" label="MapPartitionsRDD [195333] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514625 { id="cluster_514625"; isCluster="true"; label="WholeStageCodegen (13)"; 195334 [id="node_195334" labelType="html" label="ZippedPartitionsRDD2 [195334] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 195335 [id="node_195335" labelType="html" label="MapPartitionsRDD [195335] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514624 { id="cluster_514624"; isCluster="true"; label="ObjectHashAggregate"; 195336 [id="node_195336" labelType="html" label="MapPartitionsRDD [195336] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514623 { id="cluster_514623"; isCluster="true"; label="Exchange"; 195337 [id="node_195337" labelType="html" label="MapPartitionsRDD [195337] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195321->195322; 195332->195333; 195322->195334; 195333->195334; 195334->195335; 195335->195336; 195336->195337; }

195320,195321

195331,195332

digraph G { id="graph_69306"; subgraph graph_stage_69306 { id="graph_stage_69306"; isCluster="true"; label="Stage 69306"; 195346 [id="node_195346" labelType="html" label="SQLExecutionRDD [195346] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_514623 { id="cluster_514623"; isCluster="true"; label="Exchange"; 195338 [id="node_195338" labelType="html" label="ShuffledRowRDD [195338] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514622 { id="cluster_514622"; isCluster="true"; label="ObjectHashAggregate"; 195339 [id="node_195339" labelType="html" label="MapPartitionsRDD [195339] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514621 { id="cluster_514621"; isCluster="true"; label="Project"; 195340 [id="node_195340" labelType="html" label="MapPartitionsRDD [195340] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514614 { id="cluster_514614"; isCluster="true"; label="WholeStageCodegen (16)"; 195341 [id="node_195341" labelType="html" label="MapPartitionsRDD [195341] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514613 { id="cluster_514613"; isCluster="true"; label="DeserializeToObject"; 195342 [id="node_195342" labelType="html" label="MapPartitionsRDD [195342] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514612 { id="cluster_514612"; isCluster="true"; label="MapPartitions"; 195343 [id="node_195343" labelType="html" label="MapPartitionsRDD [195343] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514544 { id="cluster_514544"; isCluster="true"; label="WholeStageCodegen (19)"; 195344 [id="node_195344" labelType="html" label="MapPartitionsRDD [195344] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514523 { id="cluster_514523"; isCluster="true"; label="DeserializeToObject"; 195345 [id="node_195345" labelType="html" label="MapPartitionsRDD [195345] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514700 { id="cluster_514700"; isCluster="true"; label="mapPartitions"; 195347 [id="node_195347" labelType="html" label="MapPartitionsRDD [195347] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514701 { id="cluster_514701"; isCluster="true"; label="mapPartitions"; 195348 [id="node_195348" labelType="html" label="MapPartitionsRDD [195348] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195338->195339; 195339->195340; 195340->195341; 195341->195342; 195342->195343; 195343->195344; 195344->195345; 195345->195346; 195346->195347; 195347->195348; }

195337,195338

195348

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
69306	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:37	2 s	30/30	502.8 KiB
69305	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:36	0.4 s	30/30	653.9 KiB	502.8 KiB
69304	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:36	0.1 s	30/30	127.6 KiB	158.6 KiB
69303	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:36	0.1 s	30/30	234.9 KiB	495.3 KiB
69302	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:36	0.4 s	37/37		234.9 KiB
69301	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 7 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:05:36	0.4 s	37/37		127.6 KiB

Page: