crp-order-qty-opt-service - Details for Job 237

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:52
Duration: 23 ms
Job Group: 4a9fac36-cbda-4d33-921d-3feccc1086b2
Completed Stages: 1
Skipped Stages: 2

Enable zooming

digraph G { subgraph clusterstage_455 { label="Stage 455 (skipped)"; subgraph cluster3070 { label="Scan json "; 1154 [labelType="html" label="FileScanRDD [1154] start at FileStorageAdapterImpl.java:529"]; 1155 [labelType="html" label="MapPartitionsRDD [1155] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3067 { label="WholeStageCodegen (1)"; 1156 [labelType="html" label="MapPartitionsRDD [1156] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3066 { label="Exchange"; 1157 [labelType="html" label="MapPartitionsRDD [1157] start at FileStorageAdapterImpl.java:529"]; } } 1154->1155; 1155->1156; 1156->1157; }

digraph G { subgraph clusterstage_456 { label="Stage 456 (skipped)"; 1163 [labelType="html" label="SQLExecutionRDD [1163] [Unordered] start at FileStorageAdapterImpl.java:529"]; subgraph cluster3066 { label="Exchange"; 1158 [labelType="html" label="ShuffledRowRDD [1158] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3062 { label="WholeStageCodegen (2)"; 1159 [labelType="html" label="MapPartitionsRDD [1159] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3061 { label="DeserializeToObject"; 1160 [labelType="html" label="MapPartitionsRDD [1160] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3060 { label="MapPartitions"; 1161 [labelType="html" label="MapPartitionsRDD [1161] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3057 { label="WholeStageCodegen (3)"; 1162 [labelType="html" label="MapPartitionsRDD [1162] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3071 { label="map"; 1164 [labelType="html" label="Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000096/stream-10000000096-1/_delta_log [1164] [Cached] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3077 { label="WholeStageCodegen (1)"; 1169 [labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3076 { label="Exchange"; 1190 [labelType="html" label="MapPartitionsRDD [1190] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1158->1159; 1159->1160; 1160->1161; 1161->1162; 1162->1163; 1163->1164; 1164->1169; 1169->1190; }

1157,1158

1164

digraph G { subgraph clusterstage_457 { label="Stage 457"; 1194 [labelType="html" label="SQLExecutionRDD [1194] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1199 [labelType="html" label="SQLExecutionRDD [1199] [Unordered] start at FileStorageAdapterImpl.java:529"]; subgraph cluster3076 { label="Exchange"; 1191 [labelType="html" label="ShuffledRowRDD [1191] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3073 { label="WholeStageCodegen (2)"; 1192 [labelType="html" label="MapPartitionsRDD [1192] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3072 { label="DeserializeToObject"; 1193 [labelType="html" label="MapPartitionsRDD [1193] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3138 { label="mapPartitions"; 1195 [labelType="html" label="MapPartitionsRDD [1195] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3139 { label="zipWithIndex"; 1196 [labelType="html" label="ZippedWithIndexRDD [1196] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3148 { label="Scan"; 1197 [labelType="html" label="MapPartitionsRDD [1197] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3140 { label="WholeStageCodegen (1)"; 1198 [labelType="html" label="MapPartitionsRDD [1198] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3149 { label="map"; 1200 [labelType="html" label="Delta Source Snapshot #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000096/stream-10000000096-1/_delta_log [1200] [Cached] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3171 { label="WholeStageCodegen (1)"; 1207 [labelType="html" label="MapPartitionsRDD [1207] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3173 { label="mapPartitionsInternal"; 1208 [labelType="html" label="MapPartitionsRDD [1208] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3174 { label="map"; 1209 [labelType="html" label="MapPartitionsRDD [1209] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1191->1192; 1192->1193; 1193->1194; 1194->1195; 1195->1196; 1196->1197; 1197->1198; 1198->1199; 1199->1200; 1200->1207; 1207->1208; 1208->1209; }

1190,1191

1200

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
457	tenants-pool-286	stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) 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/02/06 10:33:52	14 ms	1/1	21.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

457

tenants-pool-286

stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
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/02/06 10:33:52

14 ms

1/1

21.0 B

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
456	default	start at FileStorageAdapterImpl.java:529 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000096/stream-10000000096-1/_delta_log org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) 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/50
455	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) 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

456

default

start at FileStorageAdapterImpl.java:529 +details

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

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
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/50

455

default

start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
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: