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

Status: SUCCEEDED
Submitted: 2026/06/09 15:55:50
Duration: 0.8 s
Associated SQL Query: 100566
Job Group: 6ced03eb-c046-4d38-8b3d-6156b8f3929b
Completed Stages: 3

Enable zooming

digraph G { id="graph_446544"; subgraph graph_stage_446544 { id="graph_stage_446544"; isCluster="true"; label="Stage 446544"; subgraph cluster_3154042 { id="cluster_3154042"; isCluster="true"; label="Scan json "; 1244179 [id="node_1244179" labelType="html" label="FileScanRDD [1244179] start at FileStorageAdapterImpl.java:174}"]; 1244180 [id="node_1244180" labelType="html" label="MapPartitionsRDD [1244180] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154039 { id="cluster_3154039"; isCluster="true"; label="WholeStageCodegen (1)"; 1244181 [id="node_1244181" labelType="html" label="MapPartitionsRDD [1244181] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154038 { id="cluster_3154038"; isCluster="true"; label="Exchange"; 1244182 [id="node_1244182" labelType="html" label="MapPartitionsRDD [1244182] start at FileStorageAdapterImpl.java:174}"]; } } 1244179->1244180; 1244180->1244181; 1244181->1244182; }

digraph G { id="graph_446545"; subgraph graph_stage_446545 { id="graph_stage_446545"; isCluster="true"; label="Stage 446545"; 1244188 [id="node_1244188" labelType="html" label="SQLExecutionRDD [1244188] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3154038 { id="cluster_3154038"; isCluster="true"; label="Exchange"; 1244183 [id="node_1244183" labelType="html" label="ShuffledRowRDD [1244183] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154034 { id="cluster_3154034"; isCluster="true"; label="WholeStageCodegen (2)"; 1244184 [id="node_1244184" labelType="html" label="MapPartitionsRDD [1244184] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154033 { id="cluster_3154033"; isCluster="true"; label="DeserializeToObject"; 1244185 [id="node_1244185" labelType="html" label="MapPartitionsRDD [1244185] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154032 { id="cluster_3154032"; isCluster="true"; label="MapPartitions"; 1244186 [id="node_1244186" labelType="html" label="MapPartitionsRDD [1244186] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154029 { id="cluster_3154029"; isCluster="true"; label="WholeStageCodegen (3)"; 1244187 [id="node_1244187" labelType="html" label="MapPartitionsRDD [1244187] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154043 { id="cluster_3154043"; isCluster="true"; label="map"; 1244189 [id="node_1244189" labelType="html" label="Delta Table State #10 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000001651/stream-10000001651-1/_delta_log [1244189] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154047 { id="cluster_3154047"; isCluster="true"; label="WholeStageCodegen (1)"; 1244190 [id="node_1244190" labelType="html" label="MapPartitionsRDD [1244190] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154046 { id="cluster_3154046"; isCluster="true"; label="ObjectHashAggregate"; 1244191 [id="node_1244191" labelType="html" label="MapPartitionsRDD [1244191] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154045 { id="cluster_3154045"; isCluster="true"; label="Exchange"; 1244192 [id="node_1244192" labelType="html" label="MapPartitionsRDD [1244192] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244183->1244184; 1244184->1244185; 1244185->1244186; 1244186->1244187; 1244187->1244188; 1244188->1244189; 1244189->1244190; 1244190->1244191; 1244191->1244192; }

1244182,1244183

1244189

digraph G { id="graph_446546"; subgraph graph_stage_446546 { id="graph_stage_446546"; isCluster="true"; label="Stage 446546"; subgraph cluster_3154045 { id="cluster_3154045"; isCluster="true"; label="Exchange"; 1244193 [id="node_1244193" labelType="html" label="ShuffledRowRDD [1244193] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154044 { id="cluster_3154044"; isCluster="true"; label="ObjectHashAggregate"; 1244194 [id="node_1244194" labelType="html" label="MapPartitionsRDD [1244194] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154050 { id="cluster_3154050"; isCluster="true"; label="mapPartitionsInternal"; 1244195 [id="node_1244195" labelType="html" label="MapPartitionsRDD [1244195] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1244193->1244194; 1244194->1244195; }

1244192,1244193

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
446546	tenants-pool-768	Delta: stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10: Compute snapshot for version: 10 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50	64 ms	1/1	6.0 KiB
446545	tenants-pool-768	Delta: stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10: Compute snapshot for version: 10 start at FileStorageAdapterImpl.java:174 +details RDD: Delta Table State #10 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000001651/stream-10000001651-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50	0.6 s	50/50	59.0 KiB	6.0 KiB
446544	tenants-pool-768	Delta: stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10: Compute snapshot for version: 10 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50	0.2 s	11/11		59.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

446546

tenants-pool-768

Delta: stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 10: Compute snapshot for version: 10 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50

64 ms

1/1

6.0 KiB

446545

tenants-pool-768

RDD: Delta Table State #10 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000001651/stream-10000001651-1/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50

0.6 s

50/50

59.0 KiB

6.0 KiB

446544

tenants-pool-768

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor888.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/06/09 15:55:50

0.2 s

11/11

59.0 KiB

Page: