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

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:16
Duration: 23 ms
Job Group: ec85e114-e059-4985-b2d1-edeafe298507
Completed Stages: 1
Skipped Stages: 2

Enable zooming

digraph G { subgraph clusterstage_155 { label="Stage 155 (skipped)"; subgraph cluster867 { label="Scan json "; 330 [labelType="html" label="FileScanRDD [330] start at FileStorageAdapterImpl.java:529"]; 331 [labelType="html" label="MapPartitionsRDD [331] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster859 { label="WholeStageCodegen (1)"; 332 [labelType="html" label="MapPartitionsRDD [332] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster858 { label="Exchange"; 333 [labelType="html" label="MapPartitionsRDD [333] start at FileStorageAdapterImpl.java:529"]; } } 330->331; 331->332; 332->333; }

digraph G { subgraph clusterstage_156 { label="Stage 156 (skipped)"; 339 [labelType="html" label="SQLExecutionRDD [339] [Unordered] start at FileStorageAdapterImpl.java:529"]; subgraph cluster858 { label="Exchange"; 334 [labelType="html" label="ShuffledRowRDD [334] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster840 { label="WholeStageCodegen (2)"; 335 [labelType="html" label="MapPartitionsRDD [335] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster839 { label="DeserializeToObject"; 336 [labelType="html" label="MapPartitionsRDD [336] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster838 { label="MapPartitions"; 337 [labelType="html" label="MapPartitionsRDD [337] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster835 { label="WholeStageCodegen (3)"; 338 [labelType="html" label="MapPartitionsRDD [338] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster868 { label="map"; 340 [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/10000000095/stream-10000000095-1/_delta_log [340] [Cached] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster874 { label="WholeStageCodegen (1)"; 344 [labelType="html" label="MapPartitionsRDD [344] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster873 { label="Exchange"; 374 [labelType="html" label="MapPartitionsRDD [374] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 334->335; 335->336; 336->337; 337->338; 338->339; 339->340; 340->344; 344->374; }

333,334

340

digraph G { subgraph clusterstage_157 { label="Stage 157"; 378 [labelType="html" label="SQLExecutionRDD [378] [Unordered] start at FileStorageAdapterImpl.java:529"]; 383 [labelType="html" label="SQLExecutionRDD [383] [Unordered] start at FileStorageAdapterImpl.java:529"]; subgraph cluster873 { label="Exchange"; 375 [labelType="html" label="ShuffledRowRDD [375] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster870 { label="WholeStageCodegen (2)"; 376 [labelType="html" label="MapPartitionsRDD [376] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster869 { label="DeserializeToObject"; 377 [labelType="html" label="MapPartitionsRDD [377] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster963 { label="mapPartitions"; 379 [labelType="html" label="MapPartitionsRDD [379] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster964 { label="zipWithIndex"; 380 [labelType="html" label="ZippedWithIndexRDD [380] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster969 { label="Scan"; 381 [labelType="html" label="MapPartitionsRDD [381] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster965 { label="WholeStageCodegen (1)"; 382 [labelType="html" label="MapPartitionsRDD [382] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster970 { label="map"; 384 [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/10000000095/stream-10000000095-1/_delta_log [384] [Cached] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster1014 { label="WholeStageCodegen (1)"; 388 [labelType="html" label="MapPartitionsRDD [388] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster1016 { label="mapPartitionsInternal"; 389 [labelType="html" label="MapPartitionsRDD [389] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster1017 { label="map"; 390 [labelType="html" label="MapPartitionsRDD [390] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 375->376; 376->377; 377->378; 378->379; 379->380; 380->381; 381->382; 382->383; 383->384; 384->388; 388->389; 389->390; }

374,375

384

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
157	tenants-pool-286	stream-10000000095-1 id = 43b2bb8d-912a-43dc-a06f-820daa41e718 runId = ec85e114-e059-4985-b2d1-edeafe298507 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 06:55:16	16 ms	1/1	21.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

157

tenants-pool-286

stream-10000000095-1 id = 43b2bb8d-912a-43dc-a06f-820daa41e718 runId = ec85e114-e059-4985-b2d1-edeafe298507 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 06:55:16

16 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
156	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/50
155	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

156

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/50

155

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: