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

Status: SUCCEEDED
Submitted: 2026/07/04 14:36:05
Duration: 1 s
Associated SQL Query: 201
Job Group: 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5
Completed Stages: 3

Enable zooming

digraph G { id="graph_919"; subgraph graph_stage_919 { id="graph_stage_919"; isCluster="true"; label="Stage 919"; 2376 [id="node_2376" labelType="html" label="SQLExecutionRDD [2376] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_7539 { id="cluster_7539"; isCluster="true"; label="Scan parquet "; 2373 [id="node_2373" labelType="html" label="FileScanRDD [2373] start at FileStorageAdapterImpl.java:174}"]; 2374 [id="node_2374" labelType="html" label="MapPartitionsRDD [2374] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7536 { id="cluster_7536"; isCluster="true"; label="WholeStageCodegen (1)"; 2375 [id="node_2375" labelType="html" label="MapPartitionsRDD [2375] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7543 { id="cluster_7543"; isCluster="true"; label="WholeStageCodegen (1)"; 2377 [id="node_2377" labelType="html" label="MapPartitionsRDD [2377] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7542 { id="cluster_7542"; isCluster="true"; label="Exchange"; 2378 [id="node_2378" labelType="html" label="MapPartitionsRDD [2378] start at FileStorageAdapterImpl.java:174}"]; } } 2373->2374; 2374->2375; 2375->2376; 2376->2377; 2377->2378; }

digraph G { id="graph_920"; subgraph graph_stage_920 { id="graph_stage_920"; isCluster="true"; label="Stage 920"; subgraph cluster_7542 { id="cluster_7542"; isCluster="true"; label="Exchange"; 2379 [id="node_2379" labelType="html" label="ShuffledRowRDD [2379] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7541 { id="cluster_7541"; isCluster="true"; label="InMemoryTableScan"; 2380 [id="node_2380" labelType="html" label="MapPartitionsRDD [2380] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2381 [id="node_2381" labelType="html" label="Exchange hashpartitioning(product#25240, plant#25241, 8), REPARTITION_BY_NUM, [plan_id=216373]\n+- *(1) Scan ExistingRDD[shardId#25237,worklistShardItemId#25238L,version#25239,product#25240,plant#25241,periodStart#25242,periodEnd#25243,qty#25244]\n [2381] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2382 [id="node_2382" labelType="html" label="MapPartitionsRDD [2382] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2383 [id="node_2383" labelType="html" label="MapPartitionsRDD [2383] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2384 [id="node_2384" labelType="html" label="MapPartitionsRDD [2384] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7540 { id="cluster_7540"; isCluster="true"; label="CollectLimit"; 2385 [id="node_2385" labelType="html" label="MapPartitionsRDD [2385] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2386 [id="node_2386" labelType="html" label="MapPartitionsRDD [2386] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 2379->2380; 2380->2381; 2381->2382; 2382->2383; 2383->2384; 2384->2385; 2385->2386; }

2378,2379

2381

digraph G { id="graph_921"; subgraph graph_stage_921 { id="graph_stage_921"; isCluster="true"; label="Stage 921"; subgraph cluster_7540 { id="cluster_7540"; isCluster="true"; label="CollectLimit"; 2387 [id="node_2387" labelType="html" label="ShuffledRowRDD [2387] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2388 [id="node_2388" labelType="html" label="MapPartitionsRDD [2388] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7545 { id="cluster_7545"; isCluster="true"; label="mapPartitionsInternal"; 2389 [id="node_2389" labelType="html" label="MapPartitionsRDD [2389] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 2387->2388; 2388->2389; }

2386,2387

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
921	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:06	7 ms	1/1
920	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:05	0.8 s	8/8	22.8 KiB	496.0 B
919	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:05	0.3 s	10/10		22.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

921

tenants-pool-21

stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:06

7 ms

1/1

920

tenants-pool-21

stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:05

0.8 s

8/8

22.8 KiB

496.0 B

919

tenants-pool-21

stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 3 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/04 14:36:05

0.3 s

10/10

22.8 KiB

Page: