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

Status: SUCCEEDED
Submitted: 2026/09/01 14:12:11
Duration: 0.4 s
Associated SQL Query: 41105
Job Group: e97f90ad-57e2-4862-afd3-46c7c1a84cab
Completed Stages: 3

Enable zooming

digraph G { id="graph_241456"; subgraph graph_stage_241456 { id="graph_stage_241456"; isCluster="true"; label="Stage 241456"; subgraph cluster_1411191 { id="cluster_1411191"; isCluster="true"; label="Scan parquet "; 540348 [id="node_540348" labelType="html" label="FileScanRDD [540348] start at FileStorageAdapterImpl.java:179}"]; 540349 [id="node_540349" labelType="html" label="MapPartitionsRDD [540349] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411187 { id="cluster_1411187"; isCluster="true"; label="WholeStageCodegen (1)"; 540350 [id="node_540350" labelType="html" label="MapPartitionsRDD [540350] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411195 { id="cluster_1411195"; isCluster="true"; label="Scan json "; 540351 [id="node_540351" labelType="html" label="FileScanRDD [540351] start at FileStorageAdapterImpl.java:179}"]; 540352 [id="node_540352" labelType="html" label="MapPartitionsRDD [540352] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411192 { id="cluster_1411192"; isCluster="true"; label="WholeStageCodegen (2)"; 540353 [id="node_540353" labelType="html" label="MapPartitionsRDD [540353] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411186 { id="cluster_1411186"; isCluster="true"; label="Union"; 540354 [id="node_540354" labelType="html" label="UnionRDD [540354] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411185 { id="cluster_1411185"; isCluster="true"; label="Exchange"; 540355 [id="node_540355" labelType="html" label="MapPartitionsRDD [540355] start at FileStorageAdapterImpl.java:179}"]; } } 540348->540349; 540349->540350; 540351->540352; 540352->540353; 540350->540354; 540353->540354; 540354->540355; }

digraph G { id="graph_241457"; subgraph graph_stage_241457 { id="graph_stage_241457"; isCluster="true"; label="Stage 241457"; 540361 [id="node_540361" labelType="html" label="SQLExecutionRDD [540361] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1411185 { id="cluster_1411185"; isCluster="true"; label="Exchange"; 540356 [id="node_540356" labelType="html" label="ShuffledRowRDD [540356] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411181 { id="cluster_1411181"; isCluster="true"; label="WholeStageCodegen (3)"; 540357 [id="node_540357" labelType="html" label="MapPartitionsRDD [540357] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411180 { id="cluster_1411180"; isCluster="true"; label="DeserializeToObject"; 540358 [id="node_540358" labelType="html" label="MapPartitionsRDD [540358] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411179 { id="cluster_1411179"; isCluster="true"; label="MapPartitions"; 540359 [id="node_540359" labelType="html" label="MapPartitionsRDD [540359] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411176 { id="cluster_1411176"; isCluster="true"; label="WholeStageCodegen (4)"; 540360 [id="node_540360" labelType="html" label="MapPartitionsRDD [540360] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411196 { id="cluster_1411196"; isCluster="true"; label="map"; 540362 [id="node_540362" labelType="html" label="Delta Table State #14 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000540/stream-10000000540-2/shardId=0_3_10000000540/_delta_log [540362] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411200 { id="cluster_1411200"; isCluster="true"; label="WholeStageCodegen (1)"; 540363 [id="node_540363" labelType="html" label="MapPartitionsRDD [540363] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411199 { id="cluster_1411199"; isCluster="true"; label="ObjectHashAggregate"; 540364 [id="node_540364" labelType="html" label="MapPartitionsRDD [540364] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411198 { id="cluster_1411198"; isCluster="true"; label="Exchange"; 540365 [id="node_540365" labelType="html" label="MapPartitionsRDD [540365] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540356->540357; 540357->540358; 540358->540359; 540359->540360; 540360->540361; 540361->540362; 540362->540363; 540363->540364; 540364->540365; }

540355,540356

540362

digraph G { id="graph_241458"; subgraph graph_stage_241458 { id="graph_stage_241458"; isCluster="true"; label="Stage 241458"; subgraph cluster_1411198 { id="cluster_1411198"; isCluster="true"; label="Exchange"; 540366 [id="node_540366" labelType="html" label="ShuffledRowRDD [540366] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411197 { id="cluster_1411197"; isCluster="true"; label="ObjectHashAggregate"; 540367 [id="node_540367" labelType="html" label="MapPartitionsRDD [540367] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411203 { id="cluster_1411203"; isCluster="true"; label="mapPartitionsInternal"; 540368 [id="node_540368" labelType="html" label="MapPartitionsRDD [540368] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540366->540367; 540367->540368; }

540365,540366

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
241458	tenants-pool-506	Delta: Delta: stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31: Filtering files for query: Compute snapshot for version: 14 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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:12:12	66 ms	1/1	6.0 KiB
241457	tenants-pool-506	Delta: Delta: stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31: Filtering files for query: Compute snapshot for version: 14 start at FileStorageAdapterImpl.java:179 +details RDD: Delta Table State #14 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000540/stream-10000000540-2/shardId=0_3_10000000540/_delta_log 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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:12:11	0.2 s	50/50	144.5 KiB	6.0 KiB
241456	tenants-pool-506	Delta: Delta: stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31: Filtering files for query: Compute snapshot for version: 14 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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:12:11	0.1 s	5/5		144.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

241458

tenants-pool-506

Delta: Delta: stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31: Filtering files for query: Compute snapshot for version: 14 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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/09/01 14:12:12

66 ms

1/1

6.0 KiB

241457

tenants-pool-506

RDD: Delta Table State #14 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000540/stream-10000000540-2/shardId=0_3_10000000540/_delta_log

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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/09/01 14:12:11

0.2 s

50/50

144.5 KiB

6.0 KiB

241456

tenants-pool-506

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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/09/01 14:12:11

0.1 s

5/5

144.5 KiB

Page: