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

Status: SUCCEEDED
Submitted: 2026/07/22 02:21:54
Duration: 2 s
Associated SQL Query: 41307
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 3

Enable zooming

digraph G { id="graph_1573790"; subgraph graph_stage_1573790 { id="graph_stage_1573790"; isCluster="true"; label="Stage 1573790"; subgraph cluster_1232285 { id="cluster_1232285"; isCluster="true"; label="Scan parquet "; 467582 [id="node_467582" labelType="html" label="FileScanRDD [467582] start at FileStorageAdapterImpl.java:598}"]; 467583 [id="node_467583" labelType="html" label="MapPartitionsRDD [467583] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232281 { id="cluster_1232281"; isCluster="true"; label="WholeStageCodegen (1)"; 467584 [id="node_467584" labelType="html" label="MapPartitionsRDD [467584] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232289 { id="cluster_1232289"; isCluster="true"; label="Scan json "; 467585 [id="node_467585" labelType="html" label="FileScanRDD [467585] start at FileStorageAdapterImpl.java:598}"]; 467586 [id="node_467586" labelType="html" label="MapPartitionsRDD [467586] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232286 { id="cluster_1232286"; isCluster="true"; label="WholeStageCodegen (2)"; 467587 [id="node_467587" labelType="html" label="MapPartitionsRDD [467587] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232280 { id="cluster_1232280"; isCluster="true"; label="Union"; 467588 [id="node_467588" labelType="html" label="UnionRDD [467588] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232279 { id="cluster_1232279"; isCluster="true"; label="Exchange"; 467589 [id="node_467589" labelType="html" label="MapPartitionsRDD [467589] start at FileStorageAdapterImpl.java:598}"]; } } 467582->467583; 467583->467584; 467585->467586; 467586->467587; 467584->467588; 467587->467588; 467588->467589; }

digraph G { id="graph_1573791"; subgraph graph_stage_1573791 { id="graph_stage_1573791"; isCluster="true"; label="Stage 1573791"; 467595 [id="node_467595" labelType="html" label="SQLExecutionRDD [467595] [Unordered] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1232279 { id="cluster_1232279"; isCluster="true"; label="Exchange"; 467590 [id="node_467590" labelType="html" label="ShuffledRowRDD [467590] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232275 { id="cluster_1232275"; isCluster="true"; label="WholeStageCodegen (3)"; 467591 [id="node_467591" labelType="html" label="MapPartitionsRDD [467591] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232274 { id="cluster_1232274"; isCluster="true"; label="DeserializeToObject"; 467592 [id="node_467592" labelType="html" label="MapPartitionsRDD [467592] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232273 { id="cluster_1232273"; isCluster="true"; label="MapPartitions"; 467593 [id="node_467593" labelType="html" label="MapPartitionsRDD [467593] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232270 { id="cluster_1232270"; isCluster="true"; label="WholeStageCodegen (4)"; 467594 [id="node_467594" labelType="html" label="MapPartitionsRDD [467594] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232290 { id="cluster_1232290"; isCluster="true"; label="map"; 467596 [id="node_467596" labelType="html" label="Delta Table State #50 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002290/stream-10000002290-1/_delta_log [467596] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232294 { id="cluster_1232294"; isCluster="true"; label="WholeStageCodegen (1)"; 467597 [id="node_467597" labelType="html" label="MapPartitionsRDD [467597] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232293 { id="cluster_1232293"; isCluster="true"; label="ObjectHashAggregate"; 467598 [id="node_467598" labelType="html" label="MapPartitionsRDD [467598] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232292 { id="cluster_1232292"; isCluster="true"; label="Exchange"; 467599 [id="node_467599" labelType="html" label="MapPartitionsRDD [467599] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 467590->467591; 467591->467592; 467592->467593; 467593->467594; 467594->467595; 467595->467596; 467596->467597; 467597->467598; 467598->467599; }

467589,467590

467596

digraph G { id="graph_1573792"; subgraph graph_stage_1573792 { id="graph_stage_1573792"; isCluster="true"; label="Stage 1573792"; subgraph cluster_1232292 { id="cluster_1232292"; isCluster="true"; label="Exchange"; 467600 [id="node_467600" labelType="html" label="ShuffledRowRDD [467600] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232291 { id="cluster_1232291"; isCluster="true"; label="ObjectHashAggregate"; 467601 [id="node_467601" labelType="html" label="MapPartitionsRDD [467601] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232297 { id="cluster_1232297"; isCluster="true"; label="mapPartitionsInternal"; 467602 [id="node_467602" labelType="html" label="MapPartitionsRDD [467602] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 467600->467601; 467601->467602; }

467599,467600

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1573792	tenants-pool-679	Delta: stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49: Compute snapshot for version: 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 02:21:56	56 ms	1/1	5.9 KiB
1573791	tenants-pool-679	Delta: stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49: Compute snapshot for version: 50 start at FileStorageAdapterImpl.java:598 +details RDD: Delta Table State #50 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002290/stream-10000002290-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 02:21:55	1 s	50/50	100.2 KiB	5.9 KiB
1573790	tenants-pool-679	Delta: stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49: Compute snapshot for version: 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 02:21:54	0.4 s	11/11		100.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1573792

tenants-pool-679

Delta: stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 49: Compute snapshot for version: 50 start at FileStorageAdapterImpl.java:598 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.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:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/07/22 02:21:56

56 ms

1/1

5.9 KiB

1573791

tenants-pool-679

RDD: Delta Table State #50 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002290/stream-10000002290-1/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.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:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/07/22 02:21:55

1 s

50/50

100.2 KiB

5.9 KiB

1573790

tenants-pool-679

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.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:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/07/22 02:21:54

0.4 s

11/11

100.2 KiB

Page: