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

Status: SUCCEEDED
Submitted: 2026/08/10 09:32:22
Duration: 0.8 s
Associated SQL Query: 677
Job Group: cd2b79e8-7be4-4311-b6ba-b3d3f3439555
Completed Stages: 3

Enable zooming

digraph G { id="graph_3154"; subgraph graph_stage_3154 { id="graph_stage_3154"; isCluster="true"; label="Stage 3154"; subgraph cluster_21444 { id="cluster_21444"; isCluster="true"; label="Scan json "; 8065 [id="node_8065" labelType="html" label="FileScanRDD [8065] start at FileStorageAdapterImpl.java:177}"]; 8066 [id="node_8066" labelType="html" label="MapPartitionsRDD [8066] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21441 { id="cluster_21441"; isCluster="true"; label="WholeStageCodegen (1)"; 8067 [id="node_8067" labelType="html" label="MapPartitionsRDD [8067] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21440 { id="cluster_21440"; isCluster="true"; label="Exchange"; 8068 [id="node_8068" labelType="html" label="MapPartitionsRDD [8068] start at FileStorageAdapterImpl.java:177}"]; } } 8065->8066; 8066->8067; 8067->8068; }

digraph G { id="graph_3155"; subgraph graph_stage_3155 { id="graph_stage_3155"; isCluster="true"; label="Stage 3155"; 8074 [id="node_8074" labelType="html" label="SQLExecutionRDD [8074] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_21440 { id="cluster_21440"; isCluster="true"; label="Exchange"; 8069 [id="node_8069" labelType="html" label="ShuffledRowRDD [8069] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21436 { id="cluster_21436"; isCluster="true"; label="WholeStageCodegen (2)"; 8070 [id="node_8070" labelType="html" label="MapPartitionsRDD [8070] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21435 { id="cluster_21435"; isCluster="true"; label="DeserializeToObject"; 8071 [id="node_8071" labelType="html" label="MapPartitionsRDD [8071] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21434 { id="cluster_21434"; isCluster="true"; label="MapPartitions"; 8072 [id="node_8072" labelType="html" label="MapPartitionsRDD [8072] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21431 { id="cluster_21431"; isCluster="true"; label="WholeStageCodegen (3)"; 8073 [id="node_8073" labelType="html" label="MapPartitionsRDD [8073] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21445 { id="cluster_21445"; isCluster="true"; label="map"; 8075 [id="node_8075" labelType="html" label="Delta Table State #6 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107/_delta_log [8075] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21449 { id="cluster_21449"; isCluster="true"; label="WholeStageCodegen (1)"; 8076 [id="node_8076" labelType="html" label="MapPartitionsRDD [8076] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21448 { id="cluster_21448"; isCluster="true"; label="ObjectHashAggregate"; 8077 [id="node_8077" labelType="html" label="MapPartitionsRDD [8077] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21447 { id="cluster_21447"; isCluster="true"; label="Exchange"; 8078 [id="node_8078" labelType="html" label="MapPartitionsRDD [8078] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8069->8070; 8070->8071; 8071->8072; 8072->8073; 8073->8074; 8074->8075; 8075->8076; 8076->8077; 8077->8078; }

8068,8069

8075

digraph G { id="graph_3156"; subgraph graph_stage_3156 { id="graph_stage_3156"; isCluster="true"; label="Stage 3156"; subgraph cluster_21447 { id="cluster_21447"; isCluster="true"; label="Exchange"; 8079 [id="node_8079" labelType="html" label="ShuffledRowRDD [8079] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21446 { id="cluster_21446"; isCluster="true"; label="ObjectHashAggregate"; 8080 [id="node_8080" labelType="html" label="MapPartitionsRDD [8080] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21452 { id="cluster_21452"; isCluster="true"; label="mapPartitionsInternal"; 8081 [id="node_8081" labelType="html" label="MapPartitionsRDD [8081] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8079->8080; 8080->8081; }

8078,8079

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3156	tenants-pool-286	Delta: Delta: stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7: Filtering files for query: Compute snapshot for version: 6 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)	2026/08/10 09:32:23	69 ms	1/1	5.8 KiB
3155	tenants-pool-286	Delta: Delta: stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7: Filtering files for query: Compute snapshot for version: 6 start at FileStorageAdapterImpl.java:177 +details RDD: Delta Table State #6 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107/_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:32:22	0.6 s	50/50	41.8 KiB	5.8 KiB
3154	tenants-pool-286	Delta: Delta: stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7: Filtering files for query: Compute snapshot for version: 6 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)	2026/08/10 09:32:22	0.1 s	7/7		41.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3156

tenants-pool-286

Delta: Delta: stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 7: Filtering files for query: Compute snapshot for version: 6 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)

2026/08/10 09:32:23

69 ms

1/1

5.8 KiB

3155

tenants-pool-286

RDD: Delta Table State #6 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107/_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:32:22

0.6 s

50/50

41.8 KiB

5.8 KiB

3154

tenants-pool-286

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:32:22

0.1 s

7/7

41.8 KiB

Page: