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

Status: SUCCEEDED
Submitted: 2026/07/05 14:10:20
Duration: 1 s
Associated SQL Query: 294
Job Group: cd2848b0-327d-42fa-997f-ab27cc4e5d7d
Completed Stages: 3

Enable zooming

digraph G { id="graph_1348"; subgraph graph_stage_1348 { id="graph_stage_1348"; isCluster="true"; label="Stage 1348"; 3474 [id="node_3474" labelType="html" label="SQLExecutionRDD [3474] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_11098 { id="cluster_11098"; isCluster="true"; label="Scan parquet "; 3471 [id="node_3471" labelType="html" label="FileScanRDD [3471] start at FileStorageAdapterImpl.java:174}"]; 3472 [id="node_3472" labelType="html" label="MapPartitionsRDD [3472] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11095 { id="cluster_11095"; isCluster="true"; label="WholeStageCodegen (1)"; 3473 [id="node_3473" labelType="html" label="MapPartitionsRDD [3473] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11102 { id="cluster_11102"; isCluster="true"; label="WholeStageCodegen (1)"; 3475 [id="node_3475" labelType="html" label="MapPartitionsRDD [3475] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11101 { id="cluster_11101"; isCluster="true"; label="Exchange"; 3476 [id="node_3476" labelType="html" label="MapPartitionsRDD [3476] start at FileStorageAdapterImpl.java:174}"]; } } 3471->3472; 3472->3473; 3473->3474; 3474->3475; 3475->3476; }

digraph G { id="graph_1349"; subgraph graph_stage_1349 { id="graph_stage_1349"; isCluster="true"; label="Stage 1349"; subgraph cluster_11101 { id="cluster_11101"; isCluster="true"; label="Exchange"; 3477 [id="node_3477" labelType="html" label="ShuffledRowRDD [3477] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11100 { id="cluster_11100"; isCluster="true"; label="InMemoryTableScan"; 3478 [id="node_3478" labelType="html" label="MapPartitionsRDD [3478] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3479 [id="node_3479" labelType="html" label="Exchange hashpartitioning(product#49874, plant#49875, 8), REPARTITION_BY_NUM, [plan_id=330158]\n+- *(1) Scan ExistingRDD[shardId#49871,worklistShardItemId#49872L,version#49873,product#49874,plant#49875,periodStart#49876,periodEnd#49877,qty#49878]\n [3479] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3480 [id="node_3480" labelType="html" label="MapPartitionsRDD [3480] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3481 [id="node_3481" labelType="html" label="MapPartitionsRDD [3481] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3482 [id="node_3482" labelType="html" label="MapPartitionsRDD [3482] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11099 { id="cluster_11099"; isCluster="true"; label="CollectLimit"; 3483 [id="node_3483" labelType="html" label="MapPartitionsRDD [3483] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3484 [id="node_3484" labelType="html" label="MapPartitionsRDD [3484] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3477->3478; 3478->3479; 3479->3480; 3480->3481; 3481->3482; 3482->3483; 3483->3484; }

3476,3477

3479

digraph G { id="graph_1350"; subgraph graph_stage_1350 { id="graph_stage_1350"; isCluster="true"; label="Stage 1350"; subgraph cluster_11099 { id="cluster_11099"; isCluster="true"; label="CollectLimit"; 3485 [id="node_3485" labelType="html" label="ShuffledRowRDD [3485] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3486 [id="node_3486" labelType="html" label="MapPartitionsRDD [3486] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11104 { id="cluster_11104"; isCluster="true"; label="mapPartitionsInternal"; 3487 [id="node_3487" labelType="html" label="MapPartitionsRDD [3487] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3485->3486; 3486->3487; }

3484,3485

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1350	tenants-pool-21	stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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) 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: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/07/05 14:10:21	72 ms	1/1
1349	tenants-pool-21	stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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) 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: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/07/05 14:10:21	0.8 s	8/8	22.6 KiB	496.0 B
1348	tenants-pool-21	stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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) 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: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/07/05 14:10:20	0.3 s	10/10		22.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1350

tenants-pool-21

stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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)
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: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/07/05 14:10:21

72 ms

1/1

1349

tenants-pool-21

stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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)
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: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/07/05 14:10:21

0.8 s

8/8

22.6 KiB

496.0 B

1348

tenants-pool-21

stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 2 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)
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: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/07/05 14:10:20

0.3 s

10/10

22.6 KiB

Page: