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

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

Enable zooming

digraph G { id="graph_27763"; subgraph graph_stage_27763 { id="graph_stage_27763"; isCluster="true"; label="Stage 27763 (skipped)"; subgraph cluster_204993 { id="cluster_204993"; isCluster="true"; label="Scan json "; 77739 [id="node_77739" labelType="html" label="FileScanRDD [77739] start at FileStorageAdapterImpl.java:179}"]; 77740 [id="node_77740" labelType="html" label="MapPartitionsRDD [77740] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204990 { id="cluster_204990"; isCluster="true"; label="WholeStageCodegen (1)"; 77741 [id="node_77741" labelType="html" label="MapPartitionsRDD [77741] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204989 { id="cluster_204989"; isCluster="true"; label="Exchange"; 77742 [id="node_77742" labelType="html" label="MapPartitionsRDD [77742] start at FileStorageAdapterImpl.java:179}"]; } } 77739->77740; 77740->77741; 77741->77742; }

digraph G { id="graph_27764"; subgraph graph_stage_27764 { id="graph_stage_27764"; isCluster="true"; label="Stage 27764"; 77748 [id="node_77748" labelType="html" label="SQLExecutionRDD [77748] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 77773 [id="node_77773" labelType="html" label="SQLExecutionRDD [77773] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_204989 { id="cluster_204989"; isCluster="true"; label="Exchange"; 77743 [id="node_77743" labelType="html" label="ShuffledRowRDD [77743] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204985 { id="cluster_204985"; isCluster="true"; label="WholeStageCodegen (2)"; 77744 [id="node_77744" labelType="html" label="MapPartitionsRDD [77744] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204984 { id="cluster_204984"; isCluster="true"; label="DeserializeToObject"; 77745 [id="node_77745" labelType="html" label="MapPartitionsRDD [77745] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204983 { id="cluster_204983"; isCluster="true"; label="MapPartitions"; 77746 [id="node_77746" labelType="html" label="MapPartitionsRDD [77746] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204980 { id="cluster_204980"; isCluster="true"; label="WholeStageCodegen (3)"; 77747 [id="node_77747" labelType="html" label="MapPartitionsRDD [77747] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_204994 { id="cluster_204994"; isCluster="true"; label="map"; 77749 [id="node_77749" labelType="html" label="Delta Table State #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=0_1_10000001127/_delta_log [77749] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205060 { id="cluster_205060"; isCluster="true"; label="WholeStageCodegen (1)"; 77771 [id="node_77771" labelType="html" label="MapPartitionsRDD [77771] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205059 { id="cluster_205059"; isCluster="true"; label="Project"; 77772 [id="node_77772" labelType="html" label="MapPartitionsRDD [77772] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205063 { id="cluster_205063"; isCluster="true"; label="map"; 77774 [id="node_77774" labelType="html" label="Delta Table State with Stats #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=0_1_10000001127/_delta_log [77774] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205592 { id="cluster_205592"; isCluster="true"; label="WholeStageCodegen (1)"; 77989 [id="node_77989" labelType="html" label="MapPartitionsRDD [77989] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205596 { id="cluster_205596"; isCluster="true"; label="mapPartitionsInternal"; 77990 [id="node_77990" labelType="html" label="MapPartitionsRDD [77990] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77743->77744; 77744->77745; 77745->77746; 77746->77747; 77747->77748; 77748->77749; 77749->77771; 77771->77772; 77772->77773; 77773->77774; 77774->77989; 77989->77990; }

77742,77743

77749

77774

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27764	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 #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=0_1_10000001127/_delta_log Delta Table State with Stats #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=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	95 ms	50/50	18.9 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27764

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 #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=0_1_10000001127/_delta_log Delta Table State with Stats #4 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001127/stream-10000001127-1/shardId=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

95 ms

50/50

18.9 KiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27763	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/5

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27763

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/5

Page: