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

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

Enable zooming

digraph G { id="graph_858"; subgraph graph_stage_858 { id="graph_stage_858"; isCluster="true"; label="Stage 858"; 2199 [id="node_2199" labelType="html" label="SQLExecutionRDD [2199] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_7118 { id="cluster_7118"; isCluster="true"; label="Scan parquet "; 2196 [id="node_2196" labelType="html" label="FileScanRDD [2196] start at FileStorageAdapterImpl.java:174}"]; 2197 [id="node_2197" labelType="html" label="MapPartitionsRDD [2197] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7115 { id="cluster_7115"; isCluster="true"; label="WholeStageCodegen (1)"; 2198 [id="node_2198" labelType="html" label="MapPartitionsRDD [2198] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7122 { id="cluster_7122"; isCluster="true"; label="WholeStageCodegen (1)"; 2200 [id="node_2200" labelType="html" label="MapPartitionsRDD [2200] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7121 { id="cluster_7121"; isCluster="true"; label="Exchange"; 2201 [id="node_2201" labelType="html" label="MapPartitionsRDD [2201] start at FileStorageAdapterImpl.java:174}"]; } } 2196->2197; 2197->2198; 2198->2199; 2199->2200; 2200->2201; }

digraph G { id="graph_859"; subgraph graph_stage_859 { id="graph_stage_859"; isCluster="true"; label="Stage 859"; subgraph cluster_7121 { id="cluster_7121"; isCluster="true"; label="Exchange"; 2202 [id="node_2202" labelType="html" label="ShuffledRowRDD [2202] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7120 { id="cluster_7120"; isCluster="true"; label="InMemoryTableScan"; 2203 [id="node_2203" labelType="html" label="MapPartitionsRDD [2203] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2204 [id="node_2204" labelType="html" label="Exchange hashpartitioning(product#25240, plant#25241, 8), REPARTITION_BY_NUM, [plan_id=215203]\n+- *(1) Scan ExistingRDD[shardId#25237,worklistShardItemId#25238L,version#25239,product#25240,plant#25241,periodStart#25242,periodEnd#25243,qty#25244]\n [2204] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2205 [id="node_2205" labelType="html" label="MapPartitionsRDD [2205] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2206 [id="node_2206" labelType="html" label="MapPartitionsRDD [2206] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2207 [id="node_2207" labelType="html" label="MapPartitionsRDD [2207] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7119 { id="cluster_7119"; isCluster="true"; label="CollectLimit"; 2208 [id="node_2208" labelType="html" label="MapPartitionsRDD [2208] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2209 [id="node_2209" labelType="html" label="MapPartitionsRDD [2209] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 2202->2203; 2203->2204; 2204->2205; 2205->2206; 2206->2207; 2207->2208; 2208->2209; }

2201,2202

2204

digraph G { id="graph_860"; subgraph graph_stage_860 { id="graph_stage_860"; isCluster="true"; label="Stage 860"; subgraph cluster_7119 { id="cluster_7119"; isCluster="true"; label="CollectLimit"; 2210 [id="node_2210" labelType="html" label="ShuffledRowRDD [2210] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2211 [id="node_2211" labelType="html" label="MapPartitionsRDD [2211] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7124 { id="cluster_7124"; isCluster="true"; label="mapPartitionsInternal"; 2212 [id="node_2212" labelType="html" label="MapPartitionsRDD [2212] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 2210->2211; 2211->2212; }

2209,2210

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
860	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 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/04 14:10:57	16 ms	1/1
859	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 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/04 14:10:56	1 s	8/8	22.8 KiB	496.0 B
858	tenants-pool-21	stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 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/04 14:10:55	0.3 s	10/10		22.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

860

tenants-pool-21

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

16 ms

1/1

859

tenants-pool-21

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

1 s

8/8

22.8 KiB

496.0 B

858

tenants-pool-21

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

0.3 s

10/10

22.8 KiB

Page: