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

Status: SUCCEEDED
Submitted: 2026/07/21 20:58:31
Duration: 3 s
Associated SQL Query: 38738
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 6

Enable zooming

digraph G { id="graph_173188"; subgraph graph_stage_173188 { id="graph_stage_173188"; isCluster="true"; label="Stage 173188"; subgraph cluster_1243358 { id="cluster_1243358"; isCluster="true"; label="Scan parquet "; 483668 [id="node_483668" labelType="html" label="FileScanRDD [483668] start at FileStorageAdapterImpl.java:179}"]; 483669 [id="node_483669" labelType="html" label="MapPartitionsRDD [483669] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243354 { id="cluster_1243354"; isCluster="true"; label="WholeStageCodegen (7)"; 483670 [id="node_483670" labelType="html" label="MapPartitionsRDD [483670] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243353 { id="cluster_1243353"; isCluster="true"; label="Exchange"; 483671 [id="node_483671" labelType="html" label="MapPartitionsRDD [483671] start at FileStorageAdapterImpl.java:179}"]; } } 483668->483669; 483669->483670; 483670->483671; }

digraph G { id="graph_173189"; subgraph graph_stage_173189 { id="graph_stage_173189"; isCluster="true"; label="Stage 173189"; subgraph cluster_1243332 { id="cluster_1243332"; isCluster="true"; label="Scan parquet "; 483657 [id="node_483657" labelType="html" label="FileScanRDD [483657] start at FileStorageAdapterImpl.java:179}"]; 483658 [id="node_483658" labelType="html" label="MapPartitionsRDD [483658] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243328 { id="cluster_1243328"; isCluster="true"; label="WholeStageCodegen (1)"; 483659 [id="node_483659" labelType="html" label="MapPartitionsRDD [483659] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243327 { id="cluster_1243327"; isCluster="true"; label="Exchange"; 483660 [id="node_483660" labelType="html" label="MapPartitionsRDD [483660] start at FileStorageAdapterImpl.java:179}"]; } } 483657->483658; 483658->483659; 483659->483660; }

digraph G { id="graph_173190"; subgraph graph_stage_173190 { id="graph_stage_173190"; isCluster="true"; label="Stage 173190"; subgraph cluster_1243327 { id="cluster_1243327"; isCluster="true"; label="Exchange"; 483661 [id="node_483661" labelType="html" label="ShuffledRowRDD [483661] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243299 { id="cluster_1243299"; isCluster="true"; label="WholeStageCodegen (5)"; 483662 [id="node_483662" labelType="html" label="MapPartitionsRDD [483662] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243298 { id="cluster_1243298"; isCluster="true"; label="Exchange"; 483663 [id="node_483663" labelType="html" label="MapPartitionsRDD [483663] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483661->483662; 483662->483663; }

483660,483661

digraph G { id="graph_173191"; subgraph graph_stage_173191 { id="graph_stage_173191"; isCluster="true"; label="Stage 173191"; subgraph cluster_1243353 { id="cluster_1243353"; isCluster="true"; label="Exchange"; 483672 [id="node_483672" labelType="html" label="ShuffledRowRDD [483672] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243338 { id="cluster_1243338"; isCluster="true"; label="WholeStageCodegen (11)"; 483673 [id="node_483673" labelType="html" label="MapPartitionsRDD [483673] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243337 { id="cluster_1243337"; isCluster="true"; label="Exchange"; 483674 [id="node_483674" labelType="html" label="MapPartitionsRDD [483674] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483672->483673; 483673->483674; }

483671,483672

digraph G { id="graph_173192"; subgraph graph_stage_173192 { id="graph_stage_173192"; isCluster="true"; label="Stage 173192"; subgraph cluster_1243298 { id="cluster_1243298"; isCluster="true"; label="Exchange"; 483664 [id="node_483664" labelType="html" label="ShuffledRowRDD [483664] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243295 { id="cluster_1243295"; isCluster="true"; label="WholeStageCodegen (6)"; 483665 [id="node_483665" labelType="html" label="MapPartitionsRDD [483665] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243337 { id="cluster_1243337"; isCluster="true"; label="Exchange"; 483675 [id="node_483675" labelType="html" label="ShuffledRowRDD [483675] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243334 { id="cluster_1243334"; isCluster="true"; label="WholeStageCodegen (12)"; 483676 [id="node_483676" labelType="html" label="MapPartitionsRDD [483676] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243291 { id="cluster_1243291"; isCluster="true"; label="WholeStageCodegen (13)"; 483677 [id="node_483677" labelType="html" label="ZippedPartitionsRDD2 [483677] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483678 [id="node_483678" labelType="html" label="MapPartitionsRDD [483678] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243290 { id="cluster_1243290"; isCluster="true"; label="ObjectHashAggregate"; 483679 [id="node_483679" labelType="html" label="MapPartitionsRDD [483679] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243289 { id="cluster_1243289"; isCluster="true"; label="Exchange"; 483680 [id="node_483680" labelType="html" label="MapPartitionsRDD [483680] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483664->483665; 483675->483676; 483665->483677; 483676->483677; 483677->483678; 483678->483679; 483679->483680; }

483663,483664

483674,483675

digraph G { id="graph_173193"; subgraph graph_stage_173193 { id="graph_stage_173193"; isCluster="true"; label="Stage 173193"; 483689 [id="node_483689" labelType="html" label="SQLExecutionRDD [483689] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1243289 { id="cluster_1243289"; isCluster="true"; label="Exchange"; 483681 [id="node_483681" labelType="html" label="ShuffledRowRDD [483681] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243288 { id="cluster_1243288"; isCluster="true"; label="ObjectHashAggregate"; 483682 [id="node_483682" labelType="html" label="MapPartitionsRDD [483682] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243287 { id="cluster_1243287"; isCluster="true"; label="Project"; 483683 [id="node_483683" labelType="html" label="MapPartitionsRDD [483683] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243266 { id="cluster_1243266"; isCluster="true"; label="WholeStageCodegen (16)"; 483684 [id="node_483684" labelType="html" label="MapPartitionsRDD [483684] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243265 { id="cluster_1243265"; isCluster="true"; label="DeserializeToObject"; 483685 [id="node_483685" labelType="html" label="MapPartitionsRDD [483685] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243264 { id="cluster_1243264"; isCluster="true"; label="MapPartitions"; 483686 [id="node_483686" labelType="html" label="MapPartitionsRDD [483686] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243211 { id="cluster_1243211"; isCluster="true"; label="WholeStageCodegen (19)"; 483687 [id="node_483687" labelType="html" label="MapPartitionsRDD [483687] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243189 { id="cluster_1243189"; isCluster="true"; label="DeserializeToObject"; 483688 [id="node_483688" labelType="html" label="MapPartitionsRDD [483688] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243366 { id="cluster_1243366"; isCluster="true"; label="mapPartitions"; 483690 [id="node_483690" labelType="html" label="MapPartitionsRDD [483690] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243367 { id="cluster_1243367"; isCluster="true"; label="mapPartitions"; 483691 [id="node_483691" labelType="html" label="MapPartitionsRDD [483691] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483681->483682; 483682->483683; 483683->483684; 483684->483685; 483685->483686; 483686->483687; 483687->483688; 483688->483689; 483689->483690; 483690->483691; }

483680,483681

483691

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
173193	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:32	2 s	30/30	8.6 KiB
173192	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:31	0.6 s	30/30	22.4 KiB	8.6 KiB
173191	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:31	0.1 s	30/30	152.9 KiB	392.0 B
173190	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:31	0.2 s	30/30	1988.9 KiB	22.0 KiB
173189	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:31	0.5 s	26/26		1988.9 KiB
173188	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 101 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.GeneratedMethodAccessor711.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 20:58:31	0.4 s	26/26		152.9 KiB

Page: