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

Status: SUCCEEDED
Submitted: 2026/04/20 06:42:34
Duration: 0.1 s
Associated SQL Query: 93
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_675"; subgraph graph_stage_675 { id="graph_stage_675"; isCluster="true"; label="Stage 675 (skipped)"; subgraph cluster_2456 { id="cluster_2456"; isCluster="true"; label="Scan json "; 868 [id="node_868" labelType="html" label="FileScanRDD [868] start at FileStorageAdapterImpl.java:171}"]; 869 [id="node_869" labelType="html" label="MapPartitionsRDD [869] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2453 { id="cluster_2453"; isCluster="true"; label="WholeStageCodegen (1)"; 870 [id="node_870" labelType="html" label="MapPartitionsRDD [870] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2452 { id="cluster_2452"; isCluster="true"; label="Exchange"; 871 [id="node_871" labelType="html" label="MapPartitionsRDD [871] start at FileStorageAdapterImpl.java:171}"]; } } 868->869; 869->870; 870->871; }

digraph G { id="graph_676"; subgraph graph_stage_676 { id="graph_stage_676"; isCluster="true"; label="Stage 676"; 877 [id="node_877" labelType="html" label="SQLExecutionRDD [877] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 881 [id="node_881" labelType="html" label="SQLExecutionRDD [881] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_2452 { id="cluster_2452"; isCluster="true"; label="Exchange"; 872 [id="node_872" labelType="html" label="ShuffledRowRDD [872] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2448 { id="cluster_2448"; isCluster="true"; label="WholeStageCodegen (2)"; 873 [id="node_873" labelType="html" label="MapPartitionsRDD [873] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2447 { id="cluster_2447"; isCluster="true"; label="DeserializeToObject"; 874 [id="node_874" labelType="html" label="MapPartitionsRDD [874] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2446 { id="cluster_2446"; isCluster="true"; label="MapPartitions"; 875 [id="node_875" labelType="html" label="MapPartitionsRDD [875] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2443 { id="cluster_2443"; isCluster="true"; label="WholeStageCodegen (3)"; 876 [id="node_876" labelType="html" label="MapPartitionsRDD [876] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2457 { id="cluster_2457"; isCluster="true"; label="map"; 878 [id="node_878" labelType="html" label="Delta Table State #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log [878] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2459 { id="cluster_2459"; isCluster="true"; label="WholeStageCodegen (1)"; 879 [id="node_879" labelType="html" label="MapPartitionsRDD [879] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2458 { id="cluster_2458"; isCluster="true"; label="Project"; 880 [id="node_880" labelType="html" label="MapPartitionsRDD [880] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2462 { id="cluster_2462"; isCluster="true"; label="map"; 882 [id="node_882" labelType="html" label="Delta Table State with Stats #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log [882] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3207 { id="cluster_3207"; isCluster="true"; label="WholeStageCodegen (1)"; 1188 [id="node_1188" labelType="html" label="MapPartitionsRDD [1188] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3211 { id="cluster_3211"; isCluster="true"; label="mapPartitionsInternal"; 1189 [id="node_1189" labelType="html" label="MapPartitionsRDD [1189] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 872->873; 873->874; 874->875; 875->876; 876->877; 877->878; 878->879; 879->880; 880->881; 881->882; 882->1188; 1188->1189; }

871,872

878

882

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
676	tenants-pool-506	Delta: stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2: Filtering files for query start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log Delta Table State with Stats #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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: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/04/20 06:42:34	0.1 s	50/50	5.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

676

tenants-pool-506

Delta: stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2: Filtering files for query start at FileStorageAdapterImpl.java:171 +details

RDD: Delta Table State #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log Delta Table State with Stats #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000004/0_1_10000000004/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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: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/04/20 06:42:34

0.1 s

50/50

5.1 KiB

Page:

Skipped Stages (1)

Page:

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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

675

default

start at FileStorageAdapterImpl.java:171 +details

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

Unknown

0/1

Page: