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

Status: SUCCEEDED
Submitted: 2026/08/31 14:20:20
Duration: 0.5 s
Associated SQL Query: 13440
Job Group: 9672435e-271f-4f72-bc82-76031aa42a7a
Completed Stages: 2

Enable zooming

digraph G { id="graph_337070"; subgraph graph_stage_337070 { id="graph_stage_337070"; isCluster="true"; label="Stage 337070"; subgraph cluster_383694 { id="cluster_383694"; isCluster="true"; label="Scan json "; 153379 [id="node_153379" labelType="html" label="FileScanRDD [153379] start at FileStorageAdapterImpl.java:596}"]; 153380 [id="node_153380" labelType="html" label="MapPartitionsRDD [153380] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383691 { id="cluster_383691"; isCluster="true"; label="WholeStageCodegen (1)"; 153381 [id="node_153381" labelType="html" label="MapPartitionsRDD [153381] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383690 { id="cluster_383690"; isCluster="true"; label="Exchange"; 153382 [id="node_153382" labelType="html" label="MapPartitionsRDD [153382] start at FileStorageAdapterImpl.java:596}"]; } } 153379->153380; 153380->153381; 153381->153382; }

digraph G { id="graph_337071"; subgraph graph_stage_337071 { id="graph_stage_337071"; isCluster="true"; label="Stage 337071"; 153388 [id="node_153388" labelType="html" label="SQLExecutionRDD [153388] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 153392 [id="node_153392" labelType="html" label="SQLExecutionRDD [153392] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_383690 { id="cluster_383690"; isCluster="true"; label="Exchange"; 153383 [id="node_153383" labelType="html" label="ShuffledRowRDD [153383] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383686 { id="cluster_383686"; isCluster="true"; label="WholeStageCodegen (2)"; 153384 [id="node_153384" labelType="html" label="MapPartitionsRDD [153384] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383685 { id="cluster_383685"; isCluster="true"; label="DeserializeToObject"; 153385 [id="node_153385" labelType="html" label="MapPartitionsRDD [153385] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383684 { id="cluster_383684"; isCluster="true"; label="MapPartitions"; 153386 [id="node_153386" labelType="html" label="MapPartitionsRDD [153386] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383681 { id="cluster_383681"; isCluster="true"; label="WholeStageCodegen (3)"; 153387 [id="node_153387" labelType="html" label="MapPartitionsRDD [153387] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383695 { id="cluster_383695"; isCluster="true"; label="map"; 153389 [id="node_153389" labelType="html" label="Delta Table State #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000000532/_delta_log [153389] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383697 { id="cluster_383697"; isCluster="true"; label="WholeStageCodegen (1)"; 153390 [id="node_153390" labelType="html" label="MapPartitionsRDD [153390] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383696 { id="cluster_383696"; isCluster="true"; label="Project"; 153391 [id="node_153391" labelType="html" label="MapPartitionsRDD [153391] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383700 { id="cluster_383700"; isCluster="true"; label="map"; 153393 [id="node_153393" labelType="html" label="Delta Table State with Stats #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000000532/_delta_log [153393] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383701 { id="cluster_383701"; isCluster="true"; label="WholeStageCodegen (1)"; 153394 [id="node_153394" labelType="html" label="MapPartitionsRDD [153394] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383705 { id="cluster_383705"; isCluster="true"; label="mapPartitionsInternal"; 153395 [id="node_153395" labelType="html" label="MapPartitionsRDD [153395] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 153383->153384; 153384->153385; 153385->153386; 153386->153387; 153387->153388; 153388->153389; 153389->153390; 153390->153391; 153391->153392; 153392->153393; 153393->153394; 153394->153395; }

153382,153383

153389

153393

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
337071	tenants-pool-506	Delta: stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20: Filtering files for query start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/31 14:20:21	0.3 s	50/50			5.5 KiB
337070	tenants-pool-506	Delta: stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20: Filtering files for query start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/31 14:20:20	0.2 s	6/6				5.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

337071

tenants-pool-506

Delta: stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20: Filtering files for query start at FileStorageAdapterImpl.java:596 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/08/31 14:20:21

0.3 s

50/50

5.5 KiB

337070

tenants-pool-506

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/08/31 14:20:20

0.2 s

6/6

5.5 KiB

Page: