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

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

Enable zooming

digraph G { id="graph_173031"; subgraph graph_stage_173031 { id="graph_stage_173031"; isCluster="true"; label="Stage 173031"; subgraph cluster_1242221 { id="cluster_1242221"; isCluster="true"; label="Scan parquet "; 483206 [id="node_483206" labelType="html" label="FileScanRDD [483206] start at FileStorageAdapterImpl.java:179}"]; 483207 [id="node_483207" labelType="html" label="MapPartitionsRDD [483207] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242217 { id="cluster_1242217"; isCluster="true"; label="WholeStageCodegen (7)"; 483208 [id="node_483208" labelType="html" label="MapPartitionsRDD [483208] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242216 { id="cluster_1242216"; isCluster="true"; label="Exchange"; 483209 [id="node_483209" labelType="html" label="MapPartitionsRDD [483209] start at FileStorageAdapterImpl.java:179}"]; } } 483206->483207; 483207->483208; 483208->483209; }

digraph G { id="graph_173032"; subgraph graph_stage_173032 { id="graph_stage_173032"; isCluster="true"; label="Stage 173032"; subgraph cluster_1242195 { id="cluster_1242195"; isCluster="true"; label="Scan parquet "; 483195 [id="node_483195" labelType="html" label="FileScanRDD [483195] start at FileStorageAdapterImpl.java:179}"]; 483196 [id="node_483196" labelType="html" label="MapPartitionsRDD [483196] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242191 { id="cluster_1242191"; isCluster="true"; label="WholeStageCodegen (1)"; 483197 [id="node_483197" labelType="html" label="MapPartitionsRDD [483197] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242190 { id="cluster_1242190"; isCluster="true"; label="Exchange"; 483198 [id="node_483198" labelType="html" label="MapPartitionsRDD [483198] start at FileStorageAdapterImpl.java:179}"]; } } 483195->483196; 483196->483197; 483197->483198; }

digraph G { id="graph_173033"; subgraph graph_stage_173033 { id="graph_stage_173033"; isCluster="true"; label="Stage 173033"; subgraph cluster_1242190 { id="cluster_1242190"; isCluster="true"; label="Exchange"; 483199 [id="node_483199" labelType="html" label="ShuffledRowRDD [483199] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242162 { id="cluster_1242162"; isCluster="true"; label="WholeStageCodegen (5)"; 483200 [id="node_483200" labelType="html" label="MapPartitionsRDD [483200] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242161 { id="cluster_1242161"; isCluster="true"; label="Exchange"; 483201 [id="node_483201" labelType="html" label="MapPartitionsRDD [483201] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483199->483200; 483200->483201; }

483198,483199

digraph G { id="graph_173034"; subgraph graph_stage_173034 { id="graph_stage_173034"; isCluster="true"; label="Stage 173034"; subgraph cluster_1242216 { id="cluster_1242216"; isCluster="true"; label="Exchange"; 483210 [id="node_483210" labelType="html" label="ShuffledRowRDD [483210] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242201 { id="cluster_1242201"; isCluster="true"; label="WholeStageCodegen (11)"; 483211 [id="node_483211" labelType="html" label="MapPartitionsRDD [483211] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242200 { id="cluster_1242200"; isCluster="true"; label="Exchange"; 483212 [id="node_483212" labelType="html" label="MapPartitionsRDD [483212] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483210->483211; 483211->483212; }

483209,483210

digraph G { id="graph_173035"; subgraph graph_stage_173035 { id="graph_stage_173035"; isCluster="true"; label="Stage 173035"; subgraph cluster_1242161 { id="cluster_1242161"; isCluster="true"; label="Exchange"; 483202 [id="node_483202" labelType="html" label="ShuffledRowRDD [483202] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242158 { id="cluster_1242158"; isCluster="true"; label="WholeStageCodegen (6)"; 483203 [id="node_483203" labelType="html" label="MapPartitionsRDD [483203] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242200 { id="cluster_1242200"; isCluster="true"; label="Exchange"; 483213 [id="node_483213" labelType="html" label="ShuffledRowRDD [483213] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242197 { id="cluster_1242197"; isCluster="true"; label="WholeStageCodegen (12)"; 483214 [id="node_483214" labelType="html" label="MapPartitionsRDD [483214] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242154 { id="cluster_1242154"; isCluster="true"; label="WholeStageCodegen (13)"; 483215 [id="node_483215" labelType="html" label="ZippedPartitionsRDD2 [483215] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483216 [id="node_483216" labelType="html" label="MapPartitionsRDD [483216] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242153 { id="cluster_1242153"; isCluster="true"; label="ObjectHashAggregate"; 483217 [id="node_483217" labelType="html" label="MapPartitionsRDD [483217] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242152 { id="cluster_1242152"; isCluster="true"; label="Exchange"; 483218 [id="node_483218" labelType="html" label="MapPartitionsRDD [483218] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483202->483203; 483213->483214; 483203->483215; 483214->483215; 483215->483216; 483216->483217; 483217->483218; }

483201,483202

483212,483213

digraph G { id="graph_173036"; subgraph graph_stage_173036 { id="graph_stage_173036"; isCluster="true"; label="Stage 173036"; 483227 [id="node_483227" labelType="html" label="SQLExecutionRDD [483227] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1242152 { id="cluster_1242152"; isCluster="true"; label="Exchange"; 483219 [id="node_483219" labelType="html" label="ShuffledRowRDD [483219] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242151 { id="cluster_1242151"; isCluster="true"; label="ObjectHashAggregate"; 483220 [id="node_483220" labelType="html" label="MapPartitionsRDD [483220] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242150 { id="cluster_1242150"; isCluster="true"; label="Project"; 483221 [id="node_483221" labelType="html" label="MapPartitionsRDD [483221] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242129 { id="cluster_1242129"; isCluster="true"; label="WholeStageCodegen (16)"; 483222 [id="node_483222" labelType="html" label="MapPartitionsRDD [483222] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242128 { id="cluster_1242128"; isCluster="true"; label="DeserializeToObject"; 483223 [id="node_483223" labelType="html" label="MapPartitionsRDD [483223] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242127 { id="cluster_1242127"; isCluster="true"; label="MapPartitions"; 483224 [id="node_483224" labelType="html" label="MapPartitionsRDD [483224] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242074 { id="cluster_1242074"; isCluster="true"; label="WholeStageCodegen (19)"; 483225 [id="node_483225" labelType="html" label="MapPartitionsRDD [483225] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242052 { id="cluster_1242052"; isCluster="true"; label="DeserializeToObject"; 483226 [id="node_483226" labelType="html" label="MapPartitionsRDD [483226] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242229 { id="cluster_1242229"; isCluster="true"; label="mapPartitions"; 483228 [id="node_483228" labelType="html" label="MapPartitionsRDD [483228] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1242230 { id="cluster_1242230"; isCluster="true"; label="mapPartitions"; 483229 [id="node_483229" labelType="html" label="MapPartitionsRDD [483229] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483219->483220; 483220->483221; 483221->483222; 483222->483223; 483223->483224; 483224->483225; 483225->483226; 483226->483227; 483227->483228; 483228->483229; }

483218,483219

483229

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
173036	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:36	2 s	30/30	17.2 KiB
173035	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:36	0.4 s	30/30	44.6 KiB	17.2 KiB
173034	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:36	0.2 s	30/30	152.9 KiB	784.0 B
173033	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:35	0.1 s	30/30	1988.9 KiB	43.8 KiB
173032	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:35	0.5 s	26/26		1988.9 KiB
173031	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 99 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:57:35	0.5 s	26/26		152.9 KiB

Page: