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

Status: SUCCEEDED
Submitted: 2026/05/22 09:54:40
Duration: 64 ms
Associated SQL Query: 73097
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_319371"; subgraph graph_stage_319371 { id="graph_stage_319371"; isCluster="true"; label="Stage 319371 (skipped)"; subgraph cluster_2296034 { id="cluster_2296034"; isCluster="true"; label="Scan json "; 885497 [id="node_885497" labelType="html" label="FileScanRDD [885497] start at FileStorageAdapterImpl.java:174}"]; 885498 [id="node_885498" labelType="html" label="MapPartitionsRDD [885498] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296031 { id="cluster_2296031"; isCluster="true"; label="WholeStageCodegen (1)"; 885499 [id="node_885499" labelType="html" label="MapPartitionsRDD [885499] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296030 { id="cluster_2296030"; isCluster="true"; label="Exchange"; 885500 [id="node_885500" labelType="html" label="MapPartitionsRDD [885500] start at FileStorageAdapterImpl.java:174}"]; } } 885497->885498; 885498->885499; 885499->885500; }

digraph G { id="graph_319372"; subgraph graph_stage_319372 { id="graph_stage_319372"; isCluster="true"; label="Stage 319372"; 885506 [id="node_885506" labelType="html" label="SQLExecutionRDD [885506] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 885510 [id="node_885510" labelType="html" label="SQLExecutionRDD [885510] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2296030 { id="cluster_2296030"; isCluster="true"; label="Exchange"; 885501 [id="node_885501" labelType="html" label="ShuffledRowRDD [885501] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296026 { id="cluster_2296026"; isCluster="true"; label="WholeStageCodegen (2)"; 885502 [id="node_885502" labelType="html" label="MapPartitionsRDD [885502] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296025 { id="cluster_2296025"; isCluster="true"; label="DeserializeToObject"; 885503 [id="node_885503" labelType="html" label="MapPartitionsRDD [885503] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296024 { id="cluster_2296024"; isCluster="true"; label="MapPartitions"; 885504 [id="node_885504" labelType="html" label="MapPartitionsRDD [885504] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296021 { id="cluster_2296021"; isCluster="true"; label="WholeStageCodegen (3)"; 885505 [id="node_885505" labelType="html" label="MapPartitionsRDD [885505] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296035 { id="cluster_2296035"; isCluster="true"; label="map"; 885507 [id="node_885507" labelType="html" label="Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log [885507] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296037 { id="cluster_2296037"; isCluster="true"; label="WholeStageCodegen (1)"; 885508 [id="node_885508" labelType="html" label="MapPartitionsRDD [885508] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296036 { id="cluster_2296036"; isCluster="true"; label="Project"; 885509 [id="node_885509" labelType="html" label="MapPartitionsRDD [885509] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2296040 { id="cluster_2296040"; isCluster="true"; label="map"; 885511 [id="node_885511" labelType="html" label="Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log [885511] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316130 { id="cluster_2316130"; isCluster="true"; label="WholeStageCodegen (1)"; 893726 [id="node_893726" labelType="html" label="MapPartitionsRDD [893726] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316129 { id="cluster_2316129"; isCluster="true"; label="Scan parquet "; 893727 [id="node_893727" labelType="html" label="MapPartitionsRDD [893727] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 885501->885502; 885502->885503; 885503->885504; 885504->885505; 885505->885506; 885506->885507; 885507->885508; 885508->885509; 885509->885510; 885510->885511; 885511->893726; 893726->893727; }

885500,885501

885507

885511

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
319372	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 39 start at FileStorageAdapterImpl.java:174 +details RDD: Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log 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) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:40	58 ms	50/50	1389.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

319372

tenants-pool-169

stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 39 start at FileStorageAdapterImpl.java:174 +details

RDD: Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000246/0_1_10000000246/_delta_log

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)
jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:40

58 ms

50/50

1389.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
319371	default	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) jdk.internal.reflect.GeneratedMethodAccessor724.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

319371

default

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)
jdk.internal.reflect.GeneratedMethodAccessor724.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: