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

Status: SUCCEEDED
Submitted: 2026/05/22 09:53:39
Duration: 2 s
Associated SQL Query: 73052
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 6

Enable zooming

digraph G { id="graph_319223"; subgraph graph_stage_319223 { id="graph_stage_319223"; isCluster="true"; label="Stage 319223"; subgraph cluster_2315081 { id="cluster_2315081"; isCluster="true"; label="Scan parquet "; 893300 [id="node_893300" labelType="html" label="FileScanRDD [893300] start at FileStorageAdapterImpl.java:174}"]; 893301 [id="node_893301" labelType="html" label="MapPartitionsRDD [893301] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315077 { id="cluster_2315077"; isCluster="true"; label="WholeStageCodegen (7)"; 893302 [id="node_893302" labelType="html" label="MapPartitionsRDD [893302] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315076 { id="cluster_2315076"; isCluster="true"; label="Exchange"; 893303 [id="node_893303" labelType="html" label="MapPartitionsRDD [893303] start at FileStorageAdapterImpl.java:174}"]; } } 893300->893301; 893301->893302; 893302->893303; }

digraph G { id="graph_319224"; subgraph graph_stage_319224 { id="graph_stage_319224"; isCluster="true"; label="Stage 319224"; subgraph cluster_2315055 { id="cluster_2315055"; isCluster="true"; label="Scan parquet "; 893289 [id="node_893289" labelType="html" label="FileScanRDD [893289] start at FileStorageAdapterImpl.java:174}"]; 893290 [id="node_893290" labelType="html" label="MapPartitionsRDD [893290] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315051 { id="cluster_2315051"; isCluster="true"; label="WholeStageCodegen (1)"; 893291 [id="node_893291" labelType="html" label="MapPartitionsRDD [893291] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315050 { id="cluster_2315050"; isCluster="true"; label="Exchange"; 893292 [id="node_893292" labelType="html" label="MapPartitionsRDD [893292] start at FileStorageAdapterImpl.java:174}"]; } } 893289->893290; 893290->893291; 893291->893292; }

digraph G { id="graph_319225"; subgraph graph_stage_319225 { id="graph_stage_319225"; isCluster="true"; label="Stage 319225"; subgraph cluster_2315050 { id="cluster_2315050"; isCluster="true"; label="Exchange"; 893293 [id="node_893293" labelType="html" label="ShuffledRowRDD [893293] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315022 { id="cluster_2315022"; isCluster="true"; label="WholeStageCodegen (5)"; 893294 [id="node_893294" labelType="html" label="MapPartitionsRDD [893294] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315021 { id="cluster_2315021"; isCluster="true"; label="Exchange"; 893295 [id="node_893295" labelType="html" label="MapPartitionsRDD [893295] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893293->893294; 893294->893295; }

893292,893293

digraph G { id="graph_319226"; subgraph graph_stage_319226 { id="graph_stage_319226"; isCluster="true"; label="Stage 319226"; subgraph cluster_2315076 { id="cluster_2315076"; isCluster="true"; label="Exchange"; 893304 [id="node_893304" labelType="html" label="ShuffledRowRDD [893304] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315061 { id="cluster_2315061"; isCluster="true"; label="WholeStageCodegen (11)"; 893305 [id="node_893305" labelType="html" label="MapPartitionsRDD [893305] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315060 { id="cluster_2315060"; isCluster="true"; label="Exchange"; 893306 [id="node_893306" labelType="html" label="MapPartitionsRDD [893306] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893304->893305; 893305->893306; }

893303,893304

digraph G { id="graph_319227"; subgraph graph_stage_319227 { id="graph_stage_319227"; isCluster="true"; label="Stage 319227"; subgraph cluster_2315021 { id="cluster_2315021"; isCluster="true"; label="Exchange"; 893296 [id="node_893296" labelType="html" label="ShuffledRowRDD [893296] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315018 { id="cluster_2315018"; isCluster="true"; label="WholeStageCodegen (6)"; 893297 [id="node_893297" labelType="html" label="MapPartitionsRDD [893297] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315060 { id="cluster_2315060"; isCluster="true"; label="Exchange"; 893307 [id="node_893307" labelType="html" label="ShuffledRowRDD [893307] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315057 { id="cluster_2315057"; isCluster="true"; label="WholeStageCodegen (12)"; 893308 [id="node_893308" labelType="html" label="MapPartitionsRDD [893308] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315014 { id="cluster_2315014"; isCluster="true"; label="WholeStageCodegen (13)"; 893309 [id="node_893309" labelType="html" label="ZippedPartitionsRDD2 [893309] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893310 [id="node_893310" labelType="html" label="MapPartitionsRDD [893310] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315013 { id="cluster_2315013"; isCluster="true"; label="ObjectHashAggregate"; 893311 [id="node_893311" labelType="html" label="MapPartitionsRDD [893311] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315012 { id="cluster_2315012"; isCluster="true"; label="Exchange"; 893312 [id="node_893312" labelType="html" label="MapPartitionsRDD [893312] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893296->893297; 893307->893308; 893297->893309; 893308->893309; 893309->893310; 893310->893311; 893311->893312; }

893295,893296

893306,893307

digraph G { id="graph_319228"; subgraph graph_stage_319228 { id="graph_stage_319228"; isCluster="true"; label="Stage 319228"; 893321 [id="node_893321" labelType="html" label="SQLExecutionRDD [893321] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2315012 { id="cluster_2315012"; isCluster="true"; label="Exchange"; 893313 [id="node_893313" labelType="html" label="ShuffledRowRDD [893313] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315011 { id="cluster_2315011"; isCluster="true"; label="ObjectHashAggregate"; 893314 [id="node_893314" labelType="html" label="MapPartitionsRDD [893314] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315010 { id="cluster_2315010"; isCluster="true"; label="Project"; 893315 [id="node_893315" labelType="html" label="MapPartitionsRDD [893315] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315003 { id="cluster_2315003"; isCluster="true"; label="WholeStageCodegen (16)"; 893316 [id="node_893316" labelType="html" label="MapPartitionsRDD [893316] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315002 { id="cluster_2315002"; isCluster="true"; label="DeserializeToObject"; 893317 [id="node_893317" labelType="html" label="MapPartitionsRDD [893317] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315001 { id="cluster_2315001"; isCluster="true"; label="MapPartitions"; 893318 [id="node_893318" labelType="html" label="MapPartitionsRDD [893318] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314934 { id="cluster_2314934"; isCluster="true"; label="WholeStageCodegen (19)"; 893319 [id="node_893319" labelType="html" label="MapPartitionsRDD [893319] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314912 { id="cluster_2314912"; isCluster="true"; label="DeserializeToObject"; 893320 [id="node_893320" labelType="html" label="MapPartitionsRDD [893320] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315089 { id="cluster_2315089"; isCluster="true"; label="mapPartitions"; 893322 [id="node_893322" labelType="html" label="MapPartitionsRDD [893322] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315090 { id="cluster_2315090"; isCluster="true"; label="mapPartitions"; 893323 [id="node_893323" labelType="html" label="MapPartitionsRDD [893323] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893313->893314; 893314->893315; 893315->893316; 893316->893317; 893317->893318; 893318->893319; 893319->893320; 893320->893321; 893321->893322; 893322->893323; }

893312,893313

893323

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
319228	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:41	0.7 s	30/30	4.9 KiB
319227	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:40	0.9 s	30/30	6.1 KiB	4.9 KiB
319226	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:39	0.4 s	30/30	2.3 KiB	1176.0 B
319225	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:39	0.4 s	30/30	5.3 KiB	5.0 KiB
319224	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:39	0.3 s	1/1		5.3 KiB
319223	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 37 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:53:39	0.3 s	1/1		2.3 KiB

Page: