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

Status: SUCCEEDED
Submitted: 2026/08/10 09:40:55
Duration: 0.8 s
Associated SQL Query: 812
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 3

Enable zooming

digraph G { id="graph_3829"; subgraph graph_stage_3829 { id="graph_stage_3829"; isCluster="true"; label="Stage 3829"; 9781 [id="node_9781" labelType="html" label="SQLExecutionRDD [9781] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_26453 { id="cluster_26453"; isCluster="true"; label="Scan parquet "; 9778 [id="node_9778" labelType="html" label="FileScanRDD [9778] start at FileStorageAdapterImpl.java:177}"]; 9779 [id="node_9779" labelType="html" label="MapPartitionsRDD [9779] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26450 { id="cluster_26450"; isCluster="true"; label="WholeStageCodegen (1)"; 9780 [id="node_9780" labelType="html" label="MapPartitionsRDD [9780] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26457 { id="cluster_26457"; isCluster="true"; label="WholeStageCodegen (1)"; 9782 [id="node_9782" labelType="html" label="MapPartitionsRDD [9782] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26456 { id="cluster_26456"; isCluster="true"; label="Exchange"; 9783 [id="node_9783" labelType="html" label="MapPartitionsRDD [9783] start at FileStorageAdapterImpl.java:177}"]; } } 9778->9779; 9779->9780; 9780->9781; 9781->9782; 9782->9783; }

digraph G { id="graph_3830"; subgraph graph_stage_3830 { id="graph_stage_3830"; isCluster="true"; label="Stage 3830"; subgraph cluster_26456 { id="cluster_26456"; isCluster="true"; label="Exchange"; 9784 [id="node_9784" labelType="html" label="ShuffledRowRDD [9784] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26455 { id="cluster_26455"; isCluster="true"; label="InMemoryTableScan"; 9785 [id="node_9785" labelType="html" label="MapPartitionsRDD [9785] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9786 [id="node_9786" labelType="html" label="Exchange hashpartitioning(product#142284, plant#142285, 20), REPARTITION_BY_NUM, [plan_id=313725]\n+- *(1) Scan ExistingRDD[shardId#142281,worklistShardItemId#142282L,version#142283,product#142284,plant#142285,periodStart#142286,periodEnd#142287,qty#142288]\n [9786] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9787 [id="node_9787" labelType="html" label="MapPartitionsRDD [9787] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9788 [id="node_9788" labelType="html" label="MapPartitionsRDD [9788] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9789 [id="node_9789" labelType="html" label="MapPartitionsRDD [9789] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26454 { id="cluster_26454"; isCluster="true"; label="CollectLimit"; 9790 [id="node_9790" labelType="html" label="MapPartitionsRDD [9790] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9791 [id="node_9791" labelType="html" label="MapPartitionsRDD [9791] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9784->9785; 9785->9786; 9786->9787; 9787->9788; 9788->9789; 9789->9790; 9790->9791; }

9783,9784

9786

digraph G { id="graph_3831"; subgraph graph_stage_3831 { id="graph_stage_3831"; isCluster="true"; label="Stage 3831"; subgraph cluster_26454 { id="cluster_26454"; isCluster="true"; label="CollectLimit"; 9792 [id="node_9792" labelType="html" label="ShuffledRowRDD [9792] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9793 [id="node_9793" labelType="html" label="MapPartitionsRDD [9793] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26459 { id="cluster_26459"; isCluster="true"; label="mapPartitionsInternal"; 9794 [id="node_9794" labelType="html" label="MapPartitionsRDD [9794] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9792->9793; 9793->9794; }

9791,9792

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3831	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:56	7 ms	1/1
3830	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:55	0.5 s	20/20	128.8 KiB	1240.0 B
3829	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:55	0.3 s	25/25		128.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3831

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:56

7 ms

1/1

3830

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:55

0.5 s

20/20

128.8 KiB

1240.0 B

3829

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 5 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:40:55

0.3 s

25/25

128.8 KiB

Page: