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

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

Enable zooming

digraph G { id="graph_241447"; subgraph graph_stage_241447 { id="graph_stage_241447"; isCluster="true"; label="Stage 241447"; 540318 [id="node_540318" labelType="html" label="SQLExecutionRDD [540318] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1411113 { id="cluster_1411113"; isCluster="true"; label="Scan parquet "; 540315 [id="node_540315" labelType="html" label="FileScanRDD [540315] start at FileStorageAdapterImpl.java:179}"]; 540316 [id="node_540316" labelType="html" label="MapPartitionsRDD [540316] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411110 { id="cluster_1411110"; isCluster="true"; label="WholeStageCodegen (1)"; 540317 [id="node_540317" labelType="html" label="MapPartitionsRDD [540317] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411117 { id="cluster_1411117"; isCluster="true"; label="WholeStageCodegen (1)"; 540319 [id="node_540319" labelType="html" label="MapPartitionsRDD [540319] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411116 { id="cluster_1411116"; isCluster="true"; label="Exchange"; 540320 [id="node_540320" labelType="html" label="MapPartitionsRDD [540320] start at FileStorageAdapterImpl.java:179}"]; } } 540315->540316; 540316->540317; 540317->540318; 540318->540319; 540319->540320; }

digraph G { id="graph_241448"; subgraph graph_stage_241448 { id="graph_stage_241448"; isCluster="true"; label="Stage 241448"; subgraph cluster_1411116 { id="cluster_1411116"; isCluster="true"; label="Exchange"; 540321 [id="node_540321" labelType="html" label="ShuffledRowRDD [540321] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411115 { id="cluster_1411115"; isCluster="true"; label="InMemoryTableScan"; 540322 [id="node_540322" labelType="html" label="MapPartitionsRDD [540322] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540323 [id="node_540323" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36545295]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540323] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540324 [id="node_540324" labelType="html" label="MapPartitionsRDD [540324] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540325 [id="node_540325" labelType="html" label="MapPartitionsRDD [540325] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540326 [id="node_540326" labelType="html" label="MapPartitionsRDD [540326] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411114 { id="cluster_1411114"; isCluster="true"; label="CollectLimit"; 540327 [id="node_540327" labelType="html" label="MapPartitionsRDD [540327] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540328 [id="node_540328" labelType="html" label="MapPartitionsRDD [540328] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540321->540322; 540322->540323; 540323->540324; 540324->540325; 540325->540326; 540326->540327; 540327->540328; }

540320,540321

540323

digraph G { id="graph_241449"; subgraph graph_stage_241449 { id="graph_stage_241449"; isCluster="true"; label="Stage 241449"; subgraph cluster_1411114 { id="cluster_1411114"; isCluster="true"; label="CollectLimit"; 540329 [id="node_540329" labelType="html" label="ShuffledRowRDD [540329] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540330 [id="node_540330" labelType="html" label="MapPartitionsRDD [540330] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411119 { id="cluster_1411119"; isCluster="true"; label="mapPartitionsInternal"; 540331 [id="node_540331" labelType="html" label="MapPartitionsRDD [540331] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540329->540330; 540330->540331; }

540328,540329

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
241449	tenants-pool-506	stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:09	14 ms	1/1
241448	tenants-pool-506	stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:08	0.7 s	30/30	5.4 MiB	1860.0 B
241447	tenants-pool-506	stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:11:55	13 s	37/37		5.4 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

241449

tenants-pool-506

stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:09

14 ms

1/1

241448

tenants-pool-506

stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:08

0.7 s

30/30

5.4 MiB

1860.0 B

241447

tenants-pool-506

stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 31 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:11:55

13 s

37/37

5.4 MiB

Page: