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

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

Enable zooming

digraph G { id="graph_69376"; subgraph graph_stage_69376 { id="graph_stage_69376"; isCluster="true"; label="Stage 69376"; subgraph cluster_515216 { id="cluster_515216"; isCluster="true"; label="Scan parquet "; 195539 [id="node_195539" labelType="html" label="FileScanRDD [195539] start at FileStorageAdapterImpl.java:179}"]; 195540 [id="node_195540" labelType="html" label="MapPartitionsRDD [195540] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515212 { id="cluster_515212"; isCluster="true"; label="WholeStageCodegen (7)"; 195541 [id="node_195541" labelType="html" label="MapPartitionsRDD [195541] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515211 { id="cluster_515211"; isCluster="true"; label="Exchange"; 195542 [id="node_195542" labelType="html" label="MapPartitionsRDD [195542] start at FileStorageAdapterImpl.java:179}"]; } } 195539->195540; 195540->195541; 195541->195542; }

digraph G { id="graph_69377"; subgraph graph_stage_69377 { id="graph_stage_69377"; isCluster="true"; label="Stage 69377"; subgraph cluster_515190 { id="cluster_515190"; isCluster="true"; label="Scan parquet "; 195528 [id="node_195528" labelType="html" label="FileScanRDD [195528] start at FileStorageAdapterImpl.java:179}"]; 195529 [id="node_195529" labelType="html" label="MapPartitionsRDD [195529] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515186 { id="cluster_515186"; isCluster="true"; label="WholeStageCodegen (1)"; 195530 [id="node_195530" labelType="html" label="MapPartitionsRDD [195530] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515185 { id="cluster_515185"; isCluster="true"; label="Exchange"; 195531 [id="node_195531" labelType="html" label="MapPartitionsRDD [195531] start at FileStorageAdapterImpl.java:179}"]; } } 195528->195529; 195529->195530; 195530->195531; }

digraph G { id="graph_69378"; subgraph graph_stage_69378 { id="graph_stage_69378"; isCluster="true"; label="Stage 69378"; subgraph cluster_515185 { id="cluster_515185"; isCluster="true"; label="Exchange"; 195532 [id="node_195532" labelType="html" label="ShuffledRowRDD [195532] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515157 { id="cluster_515157"; isCluster="true"; label="WholeStageCodegen (5)"; 195533 [id="node_195533" labelType="html" label="MapPartitionsRDD [195533] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515156 { id="cluster_515156"; isCluster="true"; label="Exchange"; 195534 [id="node_195534" labelType="html" label="MapPartitionsRDD [195534] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195532->195533; 195533->195534; }

195531,195532

digraph G { id="graph_69379"; subgraph graph_stage_69379 { id="graph_stage_69379"; isCluster="true"; label="Stage 69379"; subgraph cluster_515211 { id="cluster_515211"; isCluster="true"; label="Exchange"; 195543 [id="node_195543" labelType="html" label="ShuffledRowRDD [195543] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515196 { id="cluster_515196"; isCluster="true"; label="WholeStageCodegen (11)"; 195544 [id="node_195544" labelType="html" label="MapPartitionsRDD [195544] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515195 { id="cluster_515195"; isCluster="true"; label="Exchange"; 195545 [id="node_195545" labelType="html" label="MapPartitionsRDD [195545] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195543->195544; 195544->195545; }

195542,195543

digraph G { id="graph_69380"; subgraph graph_stage_69380 { id="graph_stage_69380"; isCluster="true"; label="Stage 69380"; subgraph cluster_515156 { id="cluster_515156"; isCluster="true"; label="Exchange"; 195535 [id="node_195535" labelType="html" label="ShuffledRowRDD [195535] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515153 { id="cluster_515153"; isCluster="true"; label="WholeStageCodegen (6)"; 195536 [id="node_195536" labelType="html" label="MapPartitionsRDD [195536] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515195 { id="cluster_515195"; isCluster="true"; label="Exchange"; 195546 [id="node_195546" labelType="html" label="ShuffledRowRDD [195546] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515192 { id="cluster_515192"; isCluster="true"; label="WholeStageCodegen (12)"; 195547 [id="node_195547" labelType="html" label="MapPartitionsRDD [195547] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515149 { id="cluster_515149"; isCluster="true"; label="WholeStageCodegen (13)"; 195548 [id="node_195548" labelType="html" label="ZippedPartitionsRDD2 [195548] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 195549 [id="node_195549" labelType="html" label="MapPartitionsRDD [195549] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515148 { id="cluster_515148"; isCluster="true"; label="ObjectHashAggregate"; 195550 [id="node_195550" labelType="html" label="MapPartitionsRDD [195550] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515147 { id="cluster_515147"; isCluster="true"; label="Exchange"; 195551 [id="node_195551" labelType="html" label="MapPartitionsRDD [195551] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195535->195536; 195546->195547; 195536->195548; 195547->195548; 195548->195549; 195549->195550; 195550->195551; }

195534,195535

195545,195546

digraph G { id="graph_69381"; subgraph graph_stage_69381 { id="graph_stage_69381"; isCluster="true"; label="Stage 69381"; 195560 [id="node_195560" labelType="html" label="SQLExecutionRDD [195560] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_515147 { id="cluster_515147"; isCluster="true"; label="Exchange"; 195552 [id="node_195552" labelType="html" label="ShuffledRowRDD [195552] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515146 { id="cluster_515146"; isCluster="true"; label="ObjectHashAggregate"; 195553 [id="node_195553" labelType="html" label="MapPartitionsRDD [195553] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515145 { id="cluster_515145"; isCluster="true"; label="Project"; 195554 [id="node_195554" labelType="html" label="MapPartitionsRDD [195554] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515124 { id="cluster_515124"; isCluster="true"; label="WholeStageCodegen (16)"; 195555 [id="node_195555" labelType="html" label="MapPartitionsRDD [195555] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515123 { id="cluster_515123"; isCluster="true"; label="DeserializeToObject"; 195556 [id="node_195556" labelType="html" label="MapPartitionsRDD [195556] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515122 { id="cluster_515122"; isCluster="true"; label="MapPartitions"; 195557 [id="node_195557" labelType="html" label="MapPartitionsRDD [195557] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515070 { id="cluster_515070"; isCluster="true"; label="WholeStageCodegen (19)"; 195558 [id="node_195558" labelType="html" label="MapPartitionsRDD [195558] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515047 { id="cluster_515047"; isCluster="true"; label="DeserializeToObject"; 195559 [id="node_195559" labelType="html" label="MapPartitionsRDD [195559] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515224 { id="cluster_515224"; isCluster="true"; label="mapPartitions"; 195561 [id="node_195561" labelType="html" label="MapPartitionsRDD [195561] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515225 { id="cluster_515225"; isCluster="true"; label="mapPartitions"; 195562 [id="node_195562" labelType="html" label="MapPartitionsRDD [195562] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195552->195553; 195553->195554; 195554->195555; 195555->195556; 195556->195557; 195557->195558; 195558->195559; 195559->195560; 195560->195561; 195561->195562; }

195551,195552

195562

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
69381	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:06	1 s	30/30	70.8 KiB
69380	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:06	0.4 s	30/30	86.9 KiB	70.8 KiB
69379	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:05	0.1 s	30/30	127.6 KiB	20.4 KiB
69378	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:05	0.1 s	30/30	234.9 KiB	66.5 KiB
69377	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:05	0.5 s	37/37		234.9 KiB
69376	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 8 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:06:05	0.4 s	37/37		127.6 KiB

Page: