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

Status: SUCCEEDED
Submitted: 2026/03/20 06:00:03
Duration: 1 s
Associated SQL Query: 3051
Job Group: 1bf8bf4d-82dd-4e25-8e77-025080b5dea7
Completed Stages: 2

Enable zooming

digraph G { id="graph_101269"; subgraph graph_stage_101269 { id="graph_stage_101269"; isCluster="true"; label="Stage 101269"; subgraph cluster_125250 { id="cluster_125250"; isCluster="true"; label="Scan json "; 47924 [id="node_47924" labelType="html" label="FileScanRDD [47924] start at FileStorageAdapterImpl.java:171}"]; 47925 [id="node_47925" labelType="html" label="MapPartitionsRDD [47925] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125247 { id="cluster_125247"; isCluster="true"; label="WholeStageCodegen (1)"; 47926 [id="node_47926" labelType="html" label="MapPartitionsRDD [47926] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125246 { id="cluster_125246"; isCluster="true"; label="Exchange"; 47927 [id="node_47927" labelType="html" label="MapPartitionsRDD [47927] start at FileStorageAdapterImpl.java:171}"]; } } 47924->47925; 47925->47926; 47926->47927; }

digraph G { id="graph_101270"; subgraph graph_stage_101270 { id="graph_stage_101270"; isCluster="true"; label="Stage 101270"; 47933 [id="node_47933" labelType="html" label="SQLExecutionRDD [47933] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 47937 [id="node_47937" labelType="html" label="SQLExecutionRDD [47937] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_125246 { id="cluster_125246"; isCluster="true"; label="Exchange"; 47928 [id="node_47928" labelType="html" label="ShuffledRowRDD [47928] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125242 { id="cluster_125242"; isCluster="true"; label="WholeStageCodegen (2)"; 47929 [id="node_47929" labelType="html" label="MapPartitionsRDD [47929] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125241 { id="cluster_125241"; isCluster="true"; label="DeserializeToObject"; 47930 [id="node_47930" labelType="html" label="MapPartitionsRDD [47930] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125240 { id="cluster_125240"; isCluster="true"; label="MapPartitions"; 47931 [id="node_47931" labelType="html" label="MapPartitionsRDD [47931] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125237 { id="cluster_125237"; isCluster="true"; label="WholeStageCodegen (3)"; 47932 [id="node_47932" labelType="html" label="MapPartitionsRDD [47932] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125284 { id="cluster_125284"; isCluster="true"; label="map"; 47934 [id="node_47934" labelType="html" label="Delta Table State #0 - hdlfs://770f0770-bd0c-456f-b83b-9649926e0857.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000678/0_1_10000000678/_delta_log [47934] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125286 { id="cluster_125286"; isCluster="true"; label="WholeStageCodegen (1)"; 47935 [id="node_47935" labelType="html" label="MapPartitionsRDD [47935] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125285 { id="cluster_125285"; isCluster="true"; label="Project"; 47936 [id="node_47936" labelType="html" label="MapPartitionsRDD [47936] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125289 { id="cluster_125289"; isCluster="true"; label="map"; 47938 [id="node_47938" labelType="html" label="Delta Table State with Stats #0 - hdlfs://770f0770-bd0c-456f-b83b-9649926e0857.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000678/0_1_10000000678/_delta_log [47938] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125290 { id="cluster_125290"; isCluster="true"; label="WholeStageCodegen (1)"; 47939 [id="node_47939" labelType="html" label="MapPartitionsRDD [47939] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_125294 { id="cluster_125294"; isCluster="true"; label="mapPartitionsInternal"; 47940 [id="node_47940" labelType="html" label="MapPartitionsRDD [47940] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 47928->47929; 47929->47930; 47930->47931; 47931->47932; 47932->47933; 47933->47934; 47934->47935; 47935->47936; 47936->47937; 47937->47938; 47938->47939; 47939->47940; }

47927,47928

47934

47938

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
101270	tenants-pool-451	Delta: stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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 06:00:03	1 s	50/50			22.9 KiB
101269	tenants-pool-451	Delta: stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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 06:00:03	0.2 s	1/1				22.9 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

101270

tenants-pool-451

Delta: stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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 06:00:03

1 s

50/50

22.9 KiB

101269

tenants-pool-451

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 06:00:03

0.2 s

1/1

22.9 KiB

Page: