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

Status: SUCCEEDED
Submitted: 2026/07/04 13:45:43
Duration: 2 s
Associated SQL Query: 179
Job Group: 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5
Completed Stages: 2

Enable zooming

digraph G { id="graph_803"; subgraph graph_stage_803 { id="graph_stage_803"; isCluster="true"; label="Stage 803"; subgraph cluster_6719 { id="cluster_6719"; isCluster="true"; label="Scan json "; 2029 [id="node_2029" labelType="html" label="FileScanRDD [2029] start at FileStorageAdapterImpl.java:174}"]; 2030 [id="node_2030" labelType="html" label="MapPartitionsRDD [2030] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6716 { id="cluster_6716"; isCluster="true"; label="WholeStageCodegen (1)"; 2031 [id="node_2031" labelType="html" label="MapPartitionsRDD [2031] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6715 { id="cluster_6715"; isCluster="true"; label="Exchange"; 2032 [id="node_2032" labelType="html" label="MapPartitionsRDD [2032] start at FileStorageAdapterImpl.java:174}"]; } } 2029->2030; 2030->2031; 2031->2032; }

digraph G { id="graph_804"; subgraph graph_stage_804 { id="graph_stage_804"; isCluster="true"; label="Stage 804"; 2038 [id="node_2038" labelType="html" label="SQLExecutionRDD [2038] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 2042 [id="node_2042" labelType="html" label="SQLExecutionRDD [2042] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_6715 { id="cluster_6715"; isCluster="true"; label="Exchange"; 2033 [id="node_2033" labelType="html" label="ShuffledRowRDD [2033] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6711 { id="cluster_6711"; isCluster="true"; label="WholeStageCodegen (2)"; 2034 [id="node_2034" labelType="html" label="MapPartitionsRDD [2034] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6710 { id="cluster_6710"; isCluster="true"; label="DeserializeToObject"; 2035 [id="node_2035" labelType="html" label="MapPartitionsRDD [2035] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6709 { id="cluster_6709"; isCluster="true"; label="MapPartitions"; 2036 [id="node_2036" labelType="html" label="MapPartitionsRDD [2036] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6706 { id="cluster_6706"; isCluster="true"; label="WholeStageCodegen (3)"; 2037 [id="node_2037" labelType="html" label="MapPartitionsRDD [2037] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6720 { id="cluster_6720"; isCluster="true"; label="map"; 2039 [id="node_2039" labelType="html" label="Delta Table State #0 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000005/0_1_10000000005/_delta_log [2039] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6722 { id="cluster_6722"; isCluster="true"; label="WholeStageCodegen (1)"; 2040 [id="node_2040" labelType="html" label="MapPartitionsRDD [2040] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6721 { id="cluster_6721"; isCluster="true"; label="Project"; 2041 [id="node_2041" labelType="html" label="MapPartitionsRDD [2041] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6725 { id="cluster_6725"; isCluster="true"; label="map"; 2043 [id="node_2043" labelType="html" label="Delta Table State with Stats #0 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000005/0_1_10000000005/_delta_log [2043] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6726 { id="cluster_6726"; isCluster="true"; label="WholeStageCodegen (1)"; 2044 [id="node_2044" labelType="html" label="MapPartitionsRDD [2044] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6730 { id="cluster_6730"; isCluster="true"; label="mapPartitionsInternal"; 2045 [id="node_2045" labelType="html" label="MapPartitionsRDD [2045] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 2033->2034; 2034->2035; 2035->2036; 2036->2037; 2037->2038; 2038->2039; 2039->2040; 2040->2041; 2041->2042; 2042->2043; 2043->2044; 2044->2045; }

2032,2033

2039

2043

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
804	tenants-pool-21	Delta: stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 1: Filtering files for query 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) 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/07/04 13:45:43	1 s	50/50			2.0 KiB
803	tenants-pool-21	Delta: stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 1: Filtering files for query 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) 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/07/04 13:45:43	0.4 s	1/1				2.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

804

tenants-pool-21

Delta: stream-10000000005-1 id = fd76e6bb-8680-48cd-8431-7b7785a9ccd7 runId = 403a882c-d7c8-41e0-9bdc-d3f1d7191eb5 batch = 1: Filtering files for query 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)
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/07/04 13:45:43

1 s

50/50

2.0 KiB

803

tenants-pool-21

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)
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/07/04 13:45:43

0.4 s

1/1

2.0 KiB

Page: