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

Status: SUCCEEDED
Submitted: 2026/03/20 20:08:27
Duration: 1 s
Associated SQL Query: 3252
Job Group: 1785dd42-a3bd-40d2-8e91-765a57162f64
Completed Stages: 2

Enable zooming

digraph G { id="graph_105915"; subgraph graph_stage_105915 { id="graph_stage_105915"; isCluster="true"; label="Stage 105915"; subgraph cluster_133481 { id="cluster_133481"; isCluster="true"; label="Scan json "; 51063 [id="node_51063" labelType="html" label="FileScanRDD [51063] start at FileStorageAdapterImpl.java:171}"]; 51064 [id="node_51064" labelType="html" label="MapPartitionsRDD [51064] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133478 { id="cluster_133478"; isCluster="true"; label="WholeStageCodegen (1)"; 51065 [id="node_51065" labelType="html" label="MapPartitionsRDD [51065] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133477 { id="cluster_133477"; isCluster="true"; label="Exchange"; 51066 [id="node_51066" labelType="html" label="MapPartitionsRDD [51066] start at FileStorageAdapterImpl.java:171}"]; } } 51063->51064; 51064->51065; 51065->51066; }

digraph G { id="graph_105916"; subgraph graph_stage_105916 { id="graph_stage_105916"; isCluster="true"; label="Stage 105916"; 51072 [id="node_51072" labelType="html" label="SQLExecutionRDD [51072] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 51076 [id="node_51076" labelType="html" label="SQLExecutionRDD [51076] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_133477 { id="cluster_133477"; isCluster="true"; label="Exchange"; 51067 [id="node_51067" labelType="html" label="ShuffledRowRDD [51067] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133473 { id="cluster_133473"; isCluster="true"; label="WholeStageCodegen (2)"; 51068 [id="node_51068" labelType="html" label="MapPartitionsRDD [51068] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133472 { id="cluster_133472"; isCluster="true"; label="DeserializeToObject"; 51069 [id="node_51069" labelType="html" label="MapPartitionsRDD [51069] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133471 { id="cluster_133471"; isCluster="true"; label="MapPartitions"; 51070 [id="node_51070" labelType="html" label="MapPartitionsRDD [51070] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133468 { id="cluster_133468"; isCluster="true"; label="WholeStageCodegen (3)"; 51071 [id="node_51071" labelType="html" label="MapPartitionsRDD [51071] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133482 { id="cluster_133482"; isCluster="true"; label="map"; 51073 [id="node_51073" labelType="html" label="Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000349/0_1_10000000349/_delta_log [51073] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133484 { id="cluster_133484"; isCluster="true"; label="WholeStageCodegen (1)"; 51074 [id="node_51074" labelType="html" label="MapPartitionsRDD [51074] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133483 { id="cluster_133483"; isCluster="true"; label="Project"; 51075 [id="node_51075" labelType="html" label="MapPartitionsRDD [51075] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133487 { id="cluster_133487"; isCluster="true"; label="map"; 51077 [id="node_51077" labelType="html" label="Delta Table State with Stats #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000349/0_1_10000000349/_delta_log [51077] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133488 { id="cluster_133488"; isCluster="true"; label="WholeStageCodegen (1)"; 51078 [id="node_51078" labelType="html" label="MapPartitionsRDD [51078] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133492 { id="cluster_133492"; isCluster="true"; label="mapPartitionsInternal"; 51079 [id="node_51079" labelType="html" label="MapPartitionsRDD [51079] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 51067->51068; 51068->51069; 51069->51070; 51070->51071; 51071->51072; 51072->51073; 51073->51074; 51074->51075; 51075->51076; 51076->51077; 51077->51078; 51078->51079; }

51066,51067

51073

51077

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
105916	tenants-pool-780	Delta: stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1: Filtering files for query 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)	2026/03/20 20:08:27	1 s	50/50			2.0 KiB
105915	tenants-pool-780	Delta: stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1: Filtering files for query 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)	2026/03/20 20:08:27	0.2 s	1/1				2.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

105916

tenants-pool-780

Delta: stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 batch = 1: Filtering files for query 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)

2026/03/20 20:08:27

1 s

50/50

2.0 KiB

105915

tenants-pool-780

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/03/20 20:08:27

0.2 s

1/1

2.0 KiB

Page: