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

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

Enable zooming

digraph G { subgraph clusterstage_152 { label="Stage 152 (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_153 { label="Stage 153"; 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_154 { label="Stage 154"; 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 cluster971 { label="WholeStageCodegen (1)"; 385 [labelType="html" label="MapPartitionsRDD [385] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster973 { label="mapPartitionsInternal"; 386 [labelType="html" label="MapPartitionsRDD [386] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster974 { label="map"; 387 [labelType="html" label="MapPartitionsRDD [387] [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->385; 385->386; 386->387; }

374,375

384

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
154	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	0.1 s	1/1
153	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	0.1 s	50/50	1560.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

154

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

0.1 s

1/1

153

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

0.1 s

50/50

1560.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
152	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

152

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: