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

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

Enable zooming

digraph G { id="graph_172656"; subgraph graph_stage_172656 { id="graph_stage_172656"; isCluster="true"; label="Stage 172656"; subgraph cluster_1239575 { id="cluster_1239575"; isCluster="true"; label="Scan parquet "; 482125 [id="node_482125" labelType="html" label="FileScanRDD [482125] start at FileStorageAdapterImpl.java:179}"]; 482126 [id="node_482126" labelType="html" label="MapPartitionsRDD [482126] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239571 { id="cluster_1239571"; isCluster="true"; label="WholeStageCodegen (1)"; 482127 [id="node_482127" labelType="html" label="MapPartitionsRDD [482127] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239570 { id="cluster_1239570"; isCluster="true"; label="Exchange"; 482128 [id="node_482128" labelType="html" label="MapPartitionsRDD [482128] start at FileStorageAdapterImpl.java:179}"]; } } 482125->482126; 482126->482127; 482127->482128; }

digraph G { id="graph_172657"; subgraph graph_stage_172657 { id="graph_stage_172657"; isCluster="true"; label="Stage 172657"; subgraph cluster_1239601 { id="cluster_1239601"; isCluster="true"; label="Scan parquet "; 482136 [id="node_482136" labelType="html" label="FileScanRDD [482136] start at FileStorageAdapterImpl.java:179}"]; 482137 [id="node_482137" labelType="html" label="MapPartitionsRDD [482137] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239597 { id="cluster_1239597"; isCluster="true"; label="WholeStageCodegen (7)"; 482138 [id="node_482138" labelType="html" label="MapPartitionsRDD [482138] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239596 { id="cluster_1239596"; isCluster="true"; label="Exchange"; 482139 [id="node_482139" labelType="html" label="MapPartitionsRDD [482139] start at FileStorageAdapterImpl.java:179}"]; } } 482136->482137; 482137->482138; 482138->482139; }

digraph G { id="graph_172658"; subgraph graph_stage_172658 { id="graph_stage_172658"; isCluster="true"; label="Stage 172658"; subgraph cluster_1239596 { id="cluster_1239596"; isCluster="true"; label="Exchange"; 482140 [id="node_482140" labelType="html" label="ShuffledRowRDD [482140] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239581 { id="cluster_1239581"; isCluster="true"; label="WholeStageCodegen (11)"; 482141 [id="node_482141" labelType="html" label="MapPartitionsRDD [482141] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239580 { id="cluster_1239580"; isCluster="true"; label="Exchange"; 482142 [id="node_482142" labelType="html" label="MapPartitionsRDD [482142] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482140->482141; 482141->482142; }

482139,482140

digraph G { id="graph_172659"; subgraph graph_stage_172659 { id="graph_stage_172659"; isCluster="true"; label="Stage 172659"; subgraph cluster_1239570 { id="cluster_1239570"; isCluster="true"; label="Exchange"; 482129 [id="node_482129" labelType="html" label="ShuffledRowRDD [482129] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239542 { id="cluster_1239542"; isCluster="true"; label="WholeStageCodegen (5)"; 482130 [id="node_482130" labelType="html" label="MapPartitionsRDD [482130] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239541 { id="cluster_1239541"; isCluster="true"; label="Exchange"; 482131 [id="node_482131" labelType="html" label="MapPartitionsRDD [482131] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482129->482130; 482130->482131; }

482128,482129

digraph G { id="graph_172660"; subgraph graph_stage_172660 { id="graph_stage_172660"; isCluster="true"; label="Stage 172660"; subgraph cluster_1239541 { id="cluster_1239541"; isCluster="true"; label="Exchange"; 482132 [id="node_482132" labelType="html" label="ShuffledRowRDD [482132] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239538 { id="cluster_1239538"; isCluster="true"; label="WholeStageCodegen (6)"; 482133 [id="node_482133" labelType="html" label="MapPartitionsRDD [482133] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239580 { id="cluster_1239580"; isCluster="true"; label="Exchange"; 482143 [id="node_482143" labelType="html" label="ShuffledRowRDD [482143] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239577 { id="cluster_1239577"; isCluster="true"; label="WholeStageCodegen (12)"; 482144 [id="node_482144" labelType="html" label="MapPartitionsRDD [482144] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239534 { id="cluster_1239534"; isCluster="true"; label="WholeStageCodegen (13)"; 482145 [id="node_482145" labelType="html" label="ZippedPartitionsRDD2 [482145] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 482146 [id="node_482146" labelType="html" label="MapPartitionsRDD [482146] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239533 { id="cluster_1239533"; isCluster="true"; label="ObjectHashAggregate"; 482147 [id="node_482147" labelType="html" label="MapPartitionsRDD [482147] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239532 { id="cluster_1239532"; isCluster="true"; label="Exchange"; 482148 [id="node_482148" labelType="html" label="MapPartitionsRDD [482148] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482132->482133; 482143->482144; 482133->482145; 482144->482145; 482145->482146; 482146->482147; 482147->482148; }

482131,482132

482142,482143

digraph G { id="graph_172661"; subgraph graph_stage_172661 { id="graph_stage_172661"; isCluster="true"; label="Stage 172661"; 482157 [id="node_482157" labelType="html" label="SQLExecutionRDD [482157] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1239532 { id="cluster_1239532"; isCluster="true"; label="Exchange"; 482149 [id="node_482149" labelType="html" label="ShuffledRowRDD [482149] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239531 { id="cluster_1239531"; isCluster="true"; label="ObjectHashAggregate"; 482150 [id="node_482150" labelType="html" label="MapPartitionsRDD [482150] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239530 { id="cluster_1239530"; isCluster="true"; label="Project"; 482151 [id="node_482151" labelType="html" label="MapPartitionsRDD [482151] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239509 { id="cluster_1239509"; isCluster="true"; label="WholeStageCodegen (16)"; 482152 [id="node_482152" labelType="html" label="MapPartitionsRDD [482152] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239508 { id="cluster_1239508"; isCluster="true"; label="DeserializeToObject"; 482153 [id="node_482153" labelType="html" label="MapPartitionsRDD [482153] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239507 { id="cluster_1239507"; isCluster="true"; label="MapPartitions"; 482154 [id="node_482154" labelType="html" label="MapPartitionsRDD [482154] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239453 { id="cluster_1239453"; isCluster="true"; label="WholeStageCodegen (19)"; 482155 [id="node_482155" labelType="html" label="MapPartitionsRDD [482155] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239432 { id="cluster_1239432"; isCluster="true"; label="DeserializeToObject"; 482156 [id="node_482156" labelType="html" label="MapPartitionsRDD [482156] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239609 { id="cluster_1239609"; isCluster="true"; label="mapPartitions"; 482158 [id="node_482158" labelType="html" label="MapPartitionsRDD [482158] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1239610 { id="cluster_1239610"; isCluster="true"; label="mapPartitions"; 482159 [id="node_482159" labelType="html" label="MapPartitionsRDD [482159] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482149->482150; 482150->482151; 482151->482152; 482152->482153; 482153->482154; 482154->482155; 482155->482156; 482156->482157; 482157->482158; 482158->482159; }

482148,482149

482159

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172661	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:21	2 s	30/30	43.0 KiB
172660	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:21	0.6 s	30/30	63.1 KiB	43.0 KiB
172659	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:20	0.2 s	30/30	1988.9 KiB	61.2 KiB
172658	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:20	0.2 s	30/30	152.9 KiB	1960.0 B
172657	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:20	0.4 s	26/26		152.9 KiB
172656	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 94 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:20	0.4 s	26/26		1988.9 KiB

Page: