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

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

Enable zooming

digraph G { id="graph_172731"; subgraph graph_stage_172731 { id="graph_stage_172731"; isCluster="true"; label="Stage 172731"; subgraph cluster_1240125 { id="cluster_1240125"; isCluster="true"; label="Scan parquet "; 482350 [id="node_482350" labelType="html" label="FileScanRDD [482350] start at FileStorageAdapterImpl.java:179}"]; 482351 [id="node_482351" labelType="html" label="MapPartitionsRDD [482351] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240121 { id="cluster_1240121"; isCluster="true"; label="WholeStageCodegen (7)"; 482352 [id="node_482352" labelType="html" label="MapPartitionsRDD [482352] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240120 { id="cluster_1240120"; isCluster="true"; label="Exchange"; 482353 [id="node_482353" labelType="html" label="MapPartitionsRDD [482353] start at FileStorageAdapterImpl.java:179}"]; } } 482350->482351; 482351->482352; 482352->482353; }

digraph G { id="graph_172732"; subgraph graph_stage_172732 { id="graph_stage_172732"; isCluster="true"; label="Stage 172732"; subgraph cluster_1240092 { id="cluster_1240092"; isCluster="true"; label="Scan parquet "; 482339 [id="node_482339" labelType="html" label="FileScanRDD [482339] start at FileStorageAdapterImpl.java:179}"]; 482340 [id="node_482340" labelType="html" label="MapPartitionsRDD [482340] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240088 { id="cluster_1240088"; isCluster="true"; label="WholeStageCodegen (1)"; 482341 [id="node_482341" labelType="html" label="MapPartitionsRDD [482341] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240087 { id="cluster_1240087"; isCluster="true"; label="Exchange"; 482342 [id="node_482342" labelType="html" label="MapPartitionsRDD [482342] start at FileStorageAdapterImpl.java:179}"]; } } 482339->482340; 482340->482341; 482341->482342; }

digraph G { id="graph_172733"; subgraph graph_stage_172733 { id="graph_stage_172733"; isCluster="true"; label="Stage 172733"; subgraph cluster_1240087 { id="cluster_1240087"; isCluster="true"; label="Exchange"; 482343 [id="node_482343" labelType="html" label="ShuffledRowRDD [482343] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240066 { id="cluster_1240066"; isCluster="true"; label="WholeStageCodegen (5)"; 482344 [id="node_482344" labelType="html" label="MapPartitionsRDD [482344] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240065 { id="cluster_1240065"; isCluster="true"; label="Exchange"; 482345 [id="node_482345" labelType="html" label="MapPartitionsRDD [482345] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482343->482344; 482344->482345; }

482342,482343

digraph G { id="graph_172734"; subgraph graph_stage_172734 { id="graph_stage_172734"; isCluster="true"; label="Stage 172734"; subgraph cluster_1240120 { id="cluster_1240120"; isCluster="true"; label="Exchange"; 482354 [id="node_482354" labelType="html" label="ShuffledRowRDD [482354] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240098 { id="cluster_1240098"; isCluster="true"; label="WholeStageCodegen (11)"; 482355 [id="node_482355" labelType="html" label="MapPartitionsRDD [482355] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240097 { id="cluster_1240097"; isCluster="true"; label="Exchange"; 482356 [id="node_482356" labelType="html" label="MapPartitionsRDD [482356] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482354->482355; 482355->482356; }

482353,482354

digraph G { id="graph_172735"; subgraph graph_stage_172735 { id="graph_stage_172735"; isCluster="true"; label="Stage 172735"; subgraph cluster_1240065 { id="cluster_1240065"; isCluster="true"; label="Exchange"; 482346 [id="node_482346" labelType="html" label="ShuffledRowRDD [482346] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240062 { id="cluster_1240062"; isCluster="true"; label="WholeStageCodegen (6)"; 482347 [id="node_482347" labelType="html" label="MapPartitionsRDD [482347] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240097 { id="cluster_1240097"; isCluster="true"; label="Exchange"; 482357 [id="node_482357" labelType="html" label="ShuffledRowRDD [482357] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240094 { id="cluster_1240094"; isCluster="true"; label="WholeStageCodegen (12)"; 482358 [id="node_482358" labelType="html" label="MapPartitionsRDD [482358] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240058 { id="cluster_1240058"; isCluster="true"; label="WholeStageCodegen (13)"; 482359 [id="node_482359" labelType="html" label="ZippedPartitionsRDD2 [482359] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 482360 [id="node_482360" labelType="html" label="MapPartitionsRDD [482360] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240057 { id="cluster_1240057"; isCluster="true"; label="ObjectHashAggregate"; 482361 [id="node_482361" labelType="html" label="MapPartitionsRDD [482361] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240056 { id="cluster_1240056"; isCluster="true"; label="Exchange"; 482362 [id="node_482362" labelType="html" label="MapPartitionsRDD [482362] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482346->482347; 482357->482358; 482347->482359; 482358->482359; 482359->482360; 482360->482361; 482361->482362; }

482345,482346

482356,482357

digraph G { id="graph_172736"; subgraph graph_stage_172736 { id="graph_stage_172736"; isCluster="true"; label="Stage 172736"; 482371 [id="node_482371" labelType="html" label="SQLExecutionRDD [482371] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1240056 { id="cluster_1240056"; isCluster="true"; label="Exchange"; 482363 [id="node_482363" labelType="html" label="ShuffledRowRDD [482363] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240055 { id="cluster_1240055"; isCluster="true"; label="ObjectHashAggregate"; 482364 [id="node_482364" labelType="html" label="MapPartitionsRDD [482364] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240054 { id="cluster_1240054"; isCluster="true"; label="Project"; 482365 [id="node_482365" labelType="html" label="MapPartitionsRDD [482365] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240033 { id="cluster_1240033"; isCluster="true"; label="WholeStageCodegen (16)"; 482366 [id="node_482366" labelType="html" label="MapPartitionsRDD [482366] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240032 { id="cluster_1240032"; isCluster="true"; label="DeserializeToObject"; 482367 [id="node_482367" labelType="html" label="MapPartitionsRDD [482367] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240031 { id="cluster_1240031"; isCluster="true"; label="MapPartitions"; 482368 [id="node_482368" labelType="html" label="MapPartitionsRDD [482368] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239977 { id="cluster_1239977"; isCluster="true"; label="WholeStageCodegen (19)"; 482369 [id="node_482369" labelType="html" label="MapPartitionsRDD [482369] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239956 { id="cluster_1239956"; isCluster="true"; label="DeserializeToObject"; 482370 [id="node_482370" labelType="html" label="MapPartitionsRDD [482370] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240133 { id="cluster_1240133"; isCluster="true"; label="mapPartitions"; 482372 [id="node_482372" labelType="html" label="MapPartitionsRDD [482372] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240134 { id="cluster_1240134"; isCluster="true"; label="mapPartitions"; 482373 [id="node_482373" labelType="html" label="MapPartitionsRDD [482373] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482363->482364; 482364->482365; 482365->482366; 482366->482367; 482367->482368; 482368->482369; 482369->482370; 482370->482371; 482371->482372; 482372->482373; }

482362,482363

482373

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172736	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:47	2 s	30/30	43.0 KiB
172735	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:46	1.0 s	30/30	63.1 KiB	43.0 KiB
172734	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:46	0.2 s	30/30	152.9 KiB	1960.0 B
172733	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:46	0.1 s	30/30	1988.9 KiB	61.2 KiB
172732	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:45	0.5 s	26/26		1988.9 KiB
172731	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 95 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:55:45	0.5 s	26/26		152.9 KiB

Page: