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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:43
Duration: 63 ms
Associated SQL Query: 6519
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_27761"; subgraph graph_stage_27761 { id="graph_stage_27761"; isCluster="true"; label="Stage 27761 (skipped)"; subgraph cluster_200770 { id="cluster_200770"; isCluster="true"; label="Scan json "; 76002 [id="node_76002" labelType="html" label="FileScanRDD [76002] start at FileStorageAdapterImpl.java:179}"]; 76003 [id="node_76003" labelType="html" label="MapPartitionsRDD [76003] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200767 { id="cluster_200767"; isCluster="true"; label="WholeStageCodegen (1)"; 76004 [id="node_76004" labelType="html" label="MapPartitionsRDD [76004] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200766 { id="cluster_200766"; isCluster="true"; label="Exchange"; 76005 [id="node_76005" labelType="html" label="MapPartitionsRDD [76005] start at FileStorageAdapterImpl.java:179}"]; } } 76002->76003; 76003->76004; 76004->76005; }

digraph G { id="graph_27762"; subgraph graph_stage_27762 { id="graph_stage_27762"; isCluster="true"; label="Stage 27762"; 76011 [id="node_76011" labelType="html" label="SQLExecutionRDD [76011] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 76015 [id="node_76015" labelType="html" label="SQLExecutionRDD [76015] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_200766 { id="cluster_200766"; isCluster="true"; label="Exchange"; 76006 [id="node_76006" labelType="html" label="ShuffledRowRDD [76006] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200762 { id="cluster_200762"; isCluster="true"; label="WholeStageCodegen (2)"; 76007 [id="node_76007" labelType="html" label="MapPartitionsRDD [76007] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200761 { id="cluster_200761"; isCluster="true"; label="DeserializeToObject"; 76008 [id="node_76008" labelType="html" label="MapPartitionsRDD [76008] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200760 { id="cluster_200760"; isCluster="true"; label="MapPartitions"; 76009 [id="node_76009" labelType="html" label="MapPartitionsRDD [76009] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200757 { id="cluster_200757"; isCluster="true"; label="WholeStageCodegen (3)"; 76010 [id="node_76010" labelType="html" label="MapPartitionsRDD [76010] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200771 { id="cluster_200771"; isCluster="true"; label="map"; 76012 [id="node_76012" labelType="html" label="Delta Table State #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log [76012] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200773 { id="cluster_200773"; isCluster="true"; label="WholeStageCodegen (1)"; 76013 [id="node_76013" labelType="html" label="MapPartitionsRDD [76013] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200772 { id="cluster_200772"; isCluster="true"; label="Project"; 76014 [id="node_76014" labelType="html" label="MapPartitionsRDD [76014] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_200776 { id="cluster_200776"; isCluster="true"; label="map"; 76016 [id="node_76016" labelType="html" label="Delta Table State with Stats #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log [76016] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205583 { id="cluster_205583"; isCluster="true"; label="WholeStageCodegen (1)"; 77987 [id="node_77987" labelType="html" label="MapPartitionsRDD [77987] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205587 { id="cluster_205587"; isCluster="true"; label="mapPartitionsInternal"; 77988 [id="node_77988" labelType="html" label="MapPartitionsRDD [77988] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 76006->76007; 76007->76008; 76008->76009; 76009->76010; 76010->76011; 76011->76012; 76012->76013; 76013->76014; 76014->76015; 76015->76016; 76016->77987; 77987->77988; }

76005,76006

76012

76016

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27762	tenants-pool-562	Delta: stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10: Filtering files for query start at FileStorageAdapterImpl.java:179 +details RDD: Delta Table State #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log Delta Table State with Stats #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:43	57 ms	50/50	12.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27762

tenants-pool-562

Delta: stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10: Filtering files for query start at FileStorageAdapterImpl.java:179 +details

RDD: Delta Table State #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log Delta Table State with Stats #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001127/0_1_10000001127/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor810.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/07/21 18:07:43

57 ms

50/50

12.6 KiB

Page:

Skipped Stages (1)

Page:

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

27761

default

start at FileStorageAdapterImpl.java:179 +details

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