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

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

Enable zooming

digraph G { id="graph_172806"; subgraph graph_stage_172806 { id="graph_stage_172806"; isCluster="true"; label="Stage 172806"; subgraph cluster_1240616 { id="cluster_1240616"; isCluster="true"; label="Scan parquet "; 482553 [id="node_482553" labelType="html" label="FileScanRDD [482553] start at FileStorageAdapterImpl.java:179}"]; 482554 [id="node_482554" labelType="html" label="MapPartitionsRDD [482554] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240612 { id="cluster_1240612"; isCluster="true"; label="WholeStageCodegen (1)"; 482555 [id="node_482555" labelType="html" label="MapPartitionsRDD [482555] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240611 { id="cluster_1240611"; isCluster="true"; label="Exchange"; 482556 [id="node_482556" labelType="html" label="MapPartitionsRDD [482556] start at FileStorageAdapterImpl.java:179}"]; } } 482553->482554; 482554->482555; 482555->482556; }

digraph G { id="graph_172807"; subgraph graph_stage_172807 { id="graph_stage_172807"; isCluster="true"; label="Stage 172807"; subgraph cluster_1240649 { id="cluster_1240649"; isCluster="true"; label="Scan parquet "; 482564 [id="node_482564" labelType="html" label="FileScanRDD [482564] start at FileStorageAdapterImpl.java:179}"]; 482565 [id="node_482565" labelType="html" label="MapPartitionsRDD [482565] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240645 { id="cluster_1240645"; isCluster="true"; label="WholeStageCodegen (7)"; 482566 [id="node_482566" labelType="html" label="MapPartitionsRDD [482566] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240644 { id="cluster_1240644"; isCluster="true"; label="Exchange"; 482567 [id="node_482567" labelType="html" label="MapPartitionsRDD [482567] start at FileStorageAdapterImpl.java:179}"]; } } 482564->482565; 482565->482566; 482566->482567; }

digraph G { id="graph_172808"; subgraph graph_stage_172808 { id="graph_stage_172808"; isCluster="true"; label="Stage 172808"; subgraph cluster_1240644 { id="cluster_1240644"; isCluster="true"; label="Exchange"; 482568 [id="node_482568" labelType="html" label="ShuffledRowRDD [482568] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240622 { id="cluster_1240622"; isCluster="true"; label="WholeStageCodegen (11)"; 482569 [id="node_482569" labelType="html" label="MapPartitionsRDD [482569] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240621 { id="cluster_1240621"; isCluster="true"; label="Exchange"; 482570 [id="node_482570" labelType="html" label="MapPartitionsRDD [482570] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482568->482569; 482569->482570; }

482567,482568

digraph G { id="graph_172809"; subgraph graph_stage_172809 { id="graph_stage_172809"; isCluster="true"; label="Stage 172809"; subgraph cluster_1240611 { id="cluster_1240611"; isCluster="true"; label="Exchange"; 482557 [id="node_482557" labelType="html" label="ShuffledRowRDD [482557] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240590 { id="cluster_1240590"; isCluster="true"; label="WholeStageCodegen (5)"; 482558 [id="node_482558" labelType="html" label="MapPartitionsRDD [482558] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240589 { id="cluster_1240589"; isCluster="true"; label="Exchange"; 482559 [id="node_482559" labelType="html" label="MapPartitionsRDD [482559] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482557->482558; 482558->482559; }

482556,482557

digraph G { id="graph_172810"; subgraph graph_stage_172810 { id="graph_stage_172810"; isCluster="true"; label="Stage 172810"; subgraph cluster_1240589 { id="cluster_1240589"; isCluster="true"; label="Exchange"; 482560 [id="node_482560" labelType="html" label="ShuffledRowRDD [482560] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240586 { id="cluster_1240586"; isCluster="true"; label="WholeStageCodegen (6)"; 482561 [id="node_482561" labelType="html" label="MapPartitionsRDD [482561] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240621 { id="cluster_1240621"; isCluster="true"; label="Exchange"; 482571 [id="node_482571" labelType="html" label="ShuffledRowRDD [482571] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240618 { id="cluster_1240618"; isCluster="true"; label="WholeStageCodegen (12)"; 482572 [id="node_482572" labelType="html" label="MapPartitionsRDD [482572] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240582 { id="cluster_1240582"; isCluster="true"; label="WholeStageCodegen (13)"; 482573 [id="node_482573" labelType="html" label="ZippedPartitionsRDD2 [482573] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 482574 [id="node_482574" labelType="html" label="MapPartitionsRDD [482574] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240581 { id="cluster_1240581"; isCluster="true"; label="ObjectHashAggregate"; 482575 [id="node_482575" labelType="html" label="MapPartitionsRDD [482575] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240580 { id="cluster_1240580"; isCluster="true"; label="Exchange"; 482576 [id="node_482576" labelType="html" label="MapPartitionsRDD [482576] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482560->482561; 482571->482572; 482561->482573; 482572->482573; 482573->482574; 482574->482575; 482575->482576; }

482559,482560

482570,482571

digraph G { id="graph_172811"; subgraph graph_stage_172811 { id="graph_stage_172811"; isCluster="true"; label="Stage 172811"; 482585 [id="node_482585" labelType="html" label="SQLExecutionRDD [482585] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1240580 { id="cluster_1240580"; isCluster="true"; label="Exchange"; 482577 [id="node_482577" labelType="html" label="ShuffledRowRDD [482577] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240579 { id="cluster_1240579"; isCluster="true"; label="ObjectHashAggregate"; 482578 [id="node_482578" labelType="html" label="MapPartitionsRDD [482578] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240578 { id="cluster_1240578"; isCluster="true"; label="Project"; 482579 [id="node_482579" labelType="html" label="MapPartitionsRDD [482579] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240557 { id="cluster_1240557"; isCluster="true"; label="WholeStageCodegen (16)"; 482580 [id="node_482580" labelType="html" label="MapPartitionsRDD [482580] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240556 { id="cluster_1240556"; isCluster="true"; label="DeserializeToObject"; 482581 [id="node_482581" labelType="html" label="MapPartitionsRDD [482581] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240555 { id="cluster_1240555"; isCluster="true"; label="MapPartitions"; 482582 [id="node_482582" labelType="html" label="MapPartitionsRDD [482582] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240502 { id="cluster_1240502"; isCluster="true"; label="WholeStageCodegen (19)"; 482583 [id="node_482583" labelType="html" label="MapPartitionsRDD [482583] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240480 { id="cluster_1240480"; isCluster="true"; label="DeserializeToObject"; 482584 [id="node_482584" labelType="html" label="MapPartitionsRDD [482584] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240657 { id="cluster_1240657"; isCluster="true"; label="mapPartitions"; 482586 [id="node_482586" labelType="html" label="MapPartitionsRDD [482586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1240658 { id="cluster_1240658"; isCluster="true"; label="mapPartitions"; 482587 [id="node_482587" labelType="html" label="MapPartitionsRDD [482587] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482577->482578; 482578->482579; 482579->482580; 482580->482581; 482581->482582; 482582->482583; 482583->482584; 482584->482585; 482585->482586; 482586->482587; }

482576,482577

482587

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172811	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:18	2 s	30/30	43.1 KiB
172810	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:17	0.6 s	30/30	101.9 KiB	43.1 KiB
172809	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:17	0.2 s	30/30	1988.9 KiB	100.0 KiB
172808	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:17	0.4 s	30/30	152.9 KiB	1960.0 B
172807	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:16	0.4 s	26/26		152.9 KiB
172806	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 96 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:56:16	0.4 s	26/26		1988.9 KiB

Page: