crp-order-quantity-kpi-service - Details for Job 1486

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:29
Duration: 96 ms
Associated SQL Query: 839
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_3923"; subgraph graph_stage_3923 { id="graph_stage_3923"; isCluster="true"; label="Stage 3923 (skipped)"; subgraph cluster_26529 { id="cluster_26529"; isCluster="true"; label="Scan json "; 9811 [id="node_9811" labelType="html" label="FileScanRDD [9811] start at FileStorageAdapterImpl.java:177}"]; 9812 [id="node_9812" labelType="html" label="MapPartitionsRDD [9812] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26526 { id="cluster_26526"; isCluster="true"; label="WholeStageCodegen (1)"; 9813 [id="node_9813" labelType="html" label="MapPartitionsRDD [9813] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26525 { id="cluster_26525"; isCluster="true"; label="Exchange"; 9814 [id="node_9814" labelType="html" label="MapPartitionsRDD [9814] start at FileStorageAdapterImpl.java:177}"]; } } 9811->9812; 9812->9813; 9813->9814; }

digraph G { id="graph_3924"; subgraph graph_stage_3924 { id="graph_stage_3924"; isCluster="true"; label="Stage 3924"; 9820 [id="node_9820" labelType="html" label="SQLExecutionRDD [9820] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9845 [id="node_9845" labelType="html" label="SQLExecutionRDD [9845] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_26525 { id="cluster_26525"; isCluster="true"; label="Exchange"; 9815 [id="node_9815" labelType="html" label="ShuffledRowRDD [9815] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26521 { id="cluster_26521"; isCluster="true"; label="WholeStageCodegen (2)"; 9816 [id="node_9816" labelType="html" label="MapPartitionsRDD [9816] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26520 { id="cluster_26520"; isCluster="true"; label="DeserializeToObject"; 9817 [id="node_9817" labelType="html" label="MapPartitionsRDD [9817] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26519 { id="cluster_26519"; isCluster="true"; label="MapPartitions"; 9818 [id="node_9818" labelType="html" label="MapPartitionsRDD [9818] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26516 { id="cluster_26516"; isCluster="true"; label="WholeStageCodegen (3)"; 9819 [id="node_9819" labelType="html" label="MapPartitionsRDD [9819] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26530 { id="cluster_26530"; isCluster="true"; label="map"; 9821 [id="node_9821" labelType="html" label="Delta Table State #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log [9821] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26596 { id="cluster_26596"; isCluster="true"; label="WholeStageCodegen (1)"; 9843 [id="node_9843" labelType="html" label="MapPartitionsRDD [9843] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26595 { id="cluster_26595"; isCluster="true"; label="Project"; 9844 [id="node_9844" labelType="html" label="MapPartitionsRDD [9844] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_26599 { id="cluster_26599"; isCluster="true"; label="map"; 9846 [id="node_9846" labelType="html" label="Delta Table State with Stats #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log [9846] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27128 { id="cluster_27128"; isCluster="true"; label="WholeStageCodegen (1)"; 10061 [id="node_10061" labelType="html" label="MapPartitionsRDD [10061] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27132 { id="cluster_27132"; isCluster="true"; label="mapPartitionsInternal"; 10062 [id="node_10062" labelType="html" label="MapPartitionsRDD [10062] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9815->9816; 9816->9817; 9817->9818; 9818->9819; 9819->9820; 9820->9821; 9821->9843; 9843->9844; 9844->9845; 9845->9846; 9846->10061; 10061->10062; }

9814,9815

9821

9846

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3924	tenants-pool-286	Delta: stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6: Filtering files for query start at FileStorageAdapterImpl.java:177 +details RDD: Delta Table State #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log Delta Table State with Stats #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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/10 09:41:29	91 ms	50/50	14.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3924

tenants-pool-286

Delta: stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6: Filtering files for query start at FileStorageAdapterImpl.java:177 +details

RDD: Delta Table State #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log Delta Table State with Stats #2 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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: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/10 09:41:29

91 ms

50/50

14.1 KiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3923	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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)	Unknown	Unknown	0/3

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3923

default

start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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: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)

Unknown

0/3

Page: