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

Status: SUCCEEDED
Submitted: 2026/03/20 20:08:25
Duration: 0.8 s
Associated SQL Query: 3247
Job Group: 1785dd42-a3bd-40d2-8e91-765a57162f64
Completed Stages: 3

Enable zooming

digraph G { id="graph_105909"; subgraph graph_stage_105909 { id="graph_stage_105909"; isCluster="true"; label="Stage 105909"; 51040 [id="node_51040" labelType="html" label="SQLExecutionRDD [51040] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_133424 { id="cluster_133424"; isCluster="true"; label="Scan parquet "; 51037 [id="node_51037" labelType="html" label="FileScanRDD [51037] start at FileStorageAdapterImpl.java:171}"]; 51038 [id="node_51038" labelType="html" label="MapPartitionsRDD [51038] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133421 { id="cluster_133421"; isCluster="true"; label="WholeStageCodegen (1)"; 51039 [id="node_51039" labelType="html" label="MapPartitionsRDD [51039] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133428 { id="cluster_133428"; isCluster="true"; label="WholeStageCodegen (1)"; 51041 [id="node_51041" labelType="html" label="MapPartitionsRDD [51041] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133427 { id="cluster_133427"; isCluster="true"; label="Exchange"; 51042 [id="node_51042" labelType="html" label="MapPartitionsRDD [51042] start at FileStorageAdapterImpl.java:171}"]; } } 51037->51038; 51038->51039; 51039->51040; 51040->51041; 51041->51042; }

digraph G { id="graph_105910"; subgraph graph_stage_105910 { id="graph_stage_105910"; isCluster="true"; label="Stage 105910"; subgraph cluster_133427 { id="cluster_133427"; isCluster="true"; label="Exchange"; 51043 [id="node_51043" labelType="html" label="ShuffledRowRDD [51043] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133426 { id="cluster_133426"; isCluster="true"; label="InMemoryTableScan"; 51044 [id="node_51044" labelType="html" label="MapPartitionsRDD [51044] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51045 [id="node_51045" labelType="html" label="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1676669]\n+- *(1) Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]\n [51045] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51046 [id="node_51046" labelType="html" label="MapPartitionsRDD [51046] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51047 [id="node_51047" labelType="html" label="MapPartitionsRDD [51047] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51048 [id="node_51048" labelType="html" label="MapPartitionsRDD [51048] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133425 { id="cluster_133425"; isCluster="true"; label="CollectLimit"; 51049 [id="node_51049" labelType="html" label="MapPartitionsRDD [51049] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51050 [id="node_51050" labelType="html" label="MapPartitionsRDD [51050] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 51043->51044; 51044->51045; 51045->51046; 51046->51047; 51047->51048; 51048->51049; 51049->51050; }

51042,51043

51045

digraph G { id="graph_105911"; subgraph graph_stage_105911 { id="graph_stage_105911"; isCluster="true"; label="Stage 105911"; subgraph cluster_133425 { id="cluster_133425"; isCluster="true"; label="CollectLimit"; 51051 [id="node_51051" labelType="html" label="ShuffledRowRDD [51051] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51052 [id="node_51052" labelType="html" label="MapPartitionsRDD [51052] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133430 { id="cluster_133430"; isCluster="true"; label="mapPartitionsInternal"; 51053 [id="node_51053" labelType="html" label="MapPartitionsRDD [51053] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 51051->51052; 51052->51053; }

51050,51051

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
105911	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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/03/20 20:08:26	6 ms	1/1
105910	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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/03/20 20:08:25	0.4 s	37/37	8.3 KiB	1488.0 B
105909	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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/03/20 20:08:25	0.4 s	28/28		8.3 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

105911

tenants-pool-780

stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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/03/20 20:08:26

6 ms

1/1

105910

tenants-pool-780

stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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/03/20 20:08:25

0.4 s

37/37

8.3 KiB

1488.0 B

105909

tenants-pool-780

stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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/03/20 20:08:25

0.4 s

28/28

8.3 KiB

Page: