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

Status: SUCCEEDED
Submitted: 2026/04/11 14:40:35
Duration: 0.2 s
Job Group: a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { id="graph_48"; subgraph graph_stage_48 { id="graph_stage_48"; isCluster="true"; label="Stage 48 (skipped)"; subgraph cluster_354 { id="cluster_354"; isCluster="true"; label="Scan json "; 140 [id="node_140" labelType="html" label="FileScanRDD [140] start at FileStorageAdapterImpl.java:174}"]; 141 [id="node_141" labelType="html" label="MapPartitionsRDD [141] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_351 { id="cluster_351"; isCluster="true"; label="WholeStageCodegen (1)"; 142 [id="node_142" labelType="html" label="MapPartitionsRDD [142] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_350 { id="cluster_350"; isCluster="true"; label="Exchange"; 143 [id="node_143" labelType="html" label="MapPartitionsRDD [143] start at FileStorageAdapterImpl.java:174}"]; } } 140->141; 141->142; 142->143; }

digraph G { id="graph_49"; subgraph graph_stage_49 { id="graph_stage_49"; isCluster="true"; label="Stage 49"; 149 [id="node_149" labelType="html" label="SQLExecutionRDD [149] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_350 { id="cluster_350"; isCluster="true"; label="Exchange"; 144 [id="node_144" labelType="html" label="ShuffledRowRDD [144] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_346 { id="cluster_346"; isCluster="true"; label="WholeStageCodegen (2)"; 145 [id="node_145" labelType="html" label="MapPartitionsRDD [145] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_345 { id="cluster_345"; isCluster="true"; label="DeserializeToObject"; 146 [id="node_146" labelType="html" label="MapPartitionsRDD [146] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_344 { id="cluster_344"; isCluster="true"; label="MapPartitions"; 147 [id="node_147" labelType="html" label="MapPartitionsRDD [147] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_341 { id="cluster_341"; isCluster="true"; label="WholeStageCodegen (3)"; 148 [id="node_148" labelType="html" label="MapPartitionsRDD [148] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_355 { id="cluster_355"; isCluster="true"; label="map"; 150 [id="node_150" labelType="html" label="Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000120/stream-10000000120-1/_delta_log [150] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_361 { id="cluster_361"; isCluster="true"; label="WholeStageCodegen (1)"; 151 [id="node_151" labelType="html" label="MapPartitionsRDD [151] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_360 { id="cluster_360"; isCluster="true"; label="Exchange"; 155 [id="node_155" labelType="html" label="MapPartitionsRDD [155] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 144->145; 145->146; 146->147; 147->148; 148->149; 149->150; 150->151; 151->155; }

143,144

150

digraph G { id="graph_50"; subgraph graph_stage_50 { id="graph_stage_50"; isCluster="true"; label="Stage 50"; 159 [id="node_159" labelType="html" label="SQLExecutionRDD [159] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 164 [id="node_164" labelType="html" label="SQLExecutionRDD [164] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_360 { id="cluster_360"; isCluster="true"; label="Exchange"; 156 [id="node_156" labelType="html" label="ShuffledRowRDD [156] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_357 { id="cluster_357"; isCluster="true"; label="WholeStageCodegen (2)"; 157 [id="node_157" labelType="html" label="MapPartitionsRDD [157] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_356 { id="cluster_356"; isCluster="true"; label="DeserializeToObject"; 158 [id="node_158" labelType="html" label="MapPartitionsRDD [158] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_380 { id="cluster_380"; isCluster="true"; label="mapPartitions"; 160 [id="node_160" labelType="html" label="MapPartitionsRDD [160] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_381 { id="cluster_381"; isCluster="true"; label="zipWithIndex"; 161 [id="node_161" labelType="html" label="ZippedWithIndexRDD [161] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_386 { id="cluster_386"; isCluster="true"; label="Scan"; 162 [id="node_162" labelType="html" label="MapPartitionsRDD [162] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_382 { id="cluster_382"; isCluster="true"; label="WholeStageCodegen (1)"; 163 [id="node_163" labelType="html" label="MapPartitionsRDD [163] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_387 { id="cluster_387"; isCluster="true"; label="map"; 165 [id="node_165" labelType="html" label="Delta Source Snapshot #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000120/stream-10000000120-1/_delta_log [165] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_388 { id="cluster_388"; isCluster="true"; label="WholeStageCodegen (1)"; 166 [id="node_166" labelType="html" label="MapPartitionsRDD [166] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_390 { id="cluster_390"; isCluster="true"; label="mapPartitionsInternal"; 167 [id="node_167" labelType="html" label="MapPartitionsRDD [167] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_391 { id="cluster_391"; isCluster="true"; label="map"; 168 [id="node_168" labelType="html" label="MapPartitionsRDD [168] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 156->157; 157->158; 158->159; 159->160; 160->161; 161->162; 162->163; 163->164; 164->165; 165->166; 166->167; 167->168; }

155,156

165

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
50	tenants-pool-286	stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c batch = 0 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/04/11 14:40:36	33 ms	1/1
49	tenants-pool-286	stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c batch = 0 start at FileStorageAdapterImpl.java:174 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000120/stream-10000000120-1/_delta_log 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/04/11 14:40:35	0.2 s	50/50	1485.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-286

stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c batch = 0 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/04/11 14:40:36

33 ms

1/1

tenants-pool-286

stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c batch = 0 start at FileStorageAdapterImpl.java:174 +details

RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000120/stream-10000000120-1/_delta_log

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/04/11 14:40:35

0.2 s

50/50

1485.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
48	default	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)	Unknown	Unknown	0/1

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

default

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)

Unknown

0/1

Page: