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

Status: SUCCEEDED
Submitted: 2026/08/10 09:39:20
Duration: 0.9 s
Associated SQL Query: 775
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 3

Enable zooming

digraph G { id="graph_3676"; subgraph graph_stage_3676 { id="graph_stage_3676"; isCluster="true"; label="Stage 3676"; 9332 [id="node_9332" labelType="html" label="SQLExecutionRDD [9332] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_25356 { id="cluster_25356"; isCluster="true"; label="Scan parquet "; 9329 [id="node_9329" labelType="html" label="FileScanRDD [9329] start at FileStorageAdapterImpl.java:177}"]; 9330 [id="node_9330" labelType="html" label="MapPartitionsRDD [9330] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25353 { id="cluster_25353"; isCluster="true"; label="WholeStageCodegen (1)"; 9331 [id="node_9331" labelType="html" label="MapPartitionsRDD [9331] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25360 { id="cluster_25360"; isCluster="true"; label="WholeStageCodegen (1)"; 9333 [id="node_9333" labelType="html" label="MapPartitionsRDD [9333] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25359 { id="cluster_25359"; isCluster="true"; label="Exchange"; 9334 [id="node_9334" labelType="html" label="MapPartitionsRDD [9334] start at FileStorageAdapterImpl.java:177}"]; } } 9329->9330; 9330->9331; 9331->9332; 9332->9333; 9333->9334; }

digraph G { id="graph_3677"; subgraph graph_stage_3677 { id="graph_stage_3677"; isCluster="true"; label="Stage 3677"; subgraph cluster_25359 { id="cluster_25359"; isCluster="true"; label="Exchange"; 9335 [id="node_9335" labelType="html" label="ShuffledRowRDD [9335] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25358 { id="cluster_25358"; isCluster="true"; label="InMemoryTableScan"; 9336 [id="node_9336" labelType="html" label="MapPartitionsRDD [9336] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9337 [id="node_9337" labelType="html" label="Exchange hashpartitioning(product#142284, plant#142285, 20), REPARTITION_BY_NUM, [plan_id=310726]\n+- *(1) Scan ExistingRDD[shardId#142281,worklistShardItemId#142282L,version#142283,product#142284,plant#142285,periodStart#142286,periodEnd#142287,qty#142288]\n [9337] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9338 [id="node_9338" labelType="html" label="MapPartitionsRDD [9338] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9339 [id="node_9339" labelType="html" label="MapPartitionsRDD [9339] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9340 [id="node_9340" labelType="html" label="MapPartitionsRDD [9340] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25357 { id="cluster_25357"; isCluster="true"; label="CollectLimit"; 9341 [id="node_9341" labelType="html" label="MapPartitionsRDD [9341] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9342 [id="node_9342" labelType="html" label="MapPartitionsRDD [9342] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9335->9336; 9336->9337; 9337->9338; 9338->9339; 9339->9340; 9340->9341; 9341->9342; }

9334,9335

9337

digraph G { id="graph_3678"; subgraph graph_stage_3678 { id="graph_stage_3678"; isCluster="true"; label="Stage 3678"; subgraph cluster_25357 { id="cluster_25357"; isCluster="true"; label="CollectLimit"; 9343 [id="node_9343" labelType="html" label="ShuffledRowRDD [9343] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9344 [id="node_9344" labelType="html" label="MapPartitionsRDD [9344] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25362 { id="cluster_25362"; isCluster="true"; label="mapPartitionsInternal"; 9345 [id="node_9345" labelType="html" label="MapPartitionsRDD [9345] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9343->9344; 9344->9345; }

9342,9343

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3678	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:21	6 ms	1/1
3677	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:20	0.5 s	20/20	127.0 KiB	1240.0 B
3676	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:20	0.3 s	25/25		127.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3678

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:21

6 ms

1/1

3677

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:20

0.5 s

20/20

127.0 KiB

1240.0 B

3676

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/08/10 09:39:20

0.3 s

25/25

127.0 KiB

Page: