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

Status: SUCCEEDED
Submitted: 2026/07/19 17:56:26
Duration: 0.8 s
Job Group: a8c33753-89a2-44e3-8dfb-1898d4a2933a
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { id="graph_354"; subgraph graph_stage_354 { id="graph_stage_354"; isCluster="true"; label="Stage 354 (skipped)"; subgraph cluster_2631 { id="cluster_2631"; isCluster="true"; label="Scan json "; 1094 [id="node_1094" labelType="html" label="FileScanRDD [1094] start at FileStorageAdapterImpl.java:179}"]; 1095 [id="node_1095" labelType="html" label="MapPartitionsRDD [1095] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2628 { id="cluster_2628"; isCluster="true"; label="WholeStageCodegen (1)"; 1096 [id="node_1096" labelType="html" label="MapPartitionsRDD [1096] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2627 { id="cluster_2627"; isCluster="true"; label="Exchange"; 1097 [id="node_1097" labelType="html" label="MapPartitionsRDD [1097] start at FileStorageAdapterImpl.java:179}"]; } } 1094->1095; 1095->1096; 1096->1097; }

digraph G { id="graph_355"; subgraph graph_stage_355 { id="graph_stage_355"; isCluster="true"; label="Stage 355"; 1103 [id="node_1103" labelType="html" label="SQLExecutionRDD [1103] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_2627 { id="cluster_2627"; isCluster="true"; label="Exchange"; 1098 [id="node_1098" labelType="html" label="ShuffledRowRDD [1098] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2623 { id="cluster_2623"; isCluster="true"; label="WholeStageCodegen (2)"; 1099 [id="node_1099" labelType="html" label="MapPartitionsRDD [1099] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2622 { id="cluster_2622"; isCluster="true"; label="DeserializeToObject"; 1100 [id="node_1100" labelType="html" label="MapPartitionsRDD [1100] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2621 { id="cluster_2621"; isCluster="true"; label="MapPartitions"; 1101 [id="node_1101" labelType="html" label="MapPartitionsRDD [1101] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2618 { id="cluster_2618"; isCluster="true"; label="WholeStageCodegen (3)"; 1102 [id="node_1102" labelType="html" label="MapPartitionsRDD [1102] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2632 { id="cluster_2632"; isCluster="true"; label="map"; 1104 [id="node_1104" labelType="html" label="Delta Table State #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001114/stream-10000001114-1/_delta_log [1104] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2638 { id="cluster_2638"; isCluster="true"; label="WholeStageCodegen (1)"; 1105 [id="node_1105" labelType="html" label="MapPartitionsRDD [1105] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2637 { id="cluster_2637"; isCluster="true"; label="Exchange"; 1109 [id="node_1109" labelType="html" label="MapPartitionsRDD [1109] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 1098->1099; 1099->1100; 1100->1101; 1101->1102; 1102->1103; 1103->1104; 1104->1105; 1105->1109; }

1097,1098

1104

digraph G { id="graph_356"; subgraph graph_stage_356 { id="graph_stage_356"; isCluster="true"; label="Stage 356"; 1113 [id="node_1113" labelType="html" label="SQLExecutionRDD [1113] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 1118 [id="node_1118" labelType="html" label="SQLExecutionRDD [1118] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_2637 { id="cluster_2637"; isCluster="true"; label="Exchange"; 1110 [id="node_1110" labelType="html" label="ShuffledRowRDD [1110] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2634 { id="cluster_2634"; isCluster="true"; label="WholeStageCodegen (2)"; 1111 [id="node_1111" labelType="html" label="MapPartitionsRDD [1111] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2633 { id="cluster_2633"; isCluster="true"; label="DeserializeToObject"; 1112 [id="node_1112" labelType="html" label="MapPartitionsRDD [1112] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2657 { id="cluster_2657"; isCluster="true"; label="mapPartitions"; 1114 [id="node_1114" labelType="html" label="MapPartitionsRDD [1114] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2658 { id="cluster_2658"; isCluster="true"; label="zipWithIndex"; 1115 [id="node_1115" labelType="html" label="ZippedWithIndexRDD [1115] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2663 { id="cluster_2663"; isCluster="true"; label="Scan"; 1116 [id="node_1116" labelType="html" label="MapPartitionsRDD [1116] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2659 { id="cluster_2659"; isCluster="true"; label="WholeStageCodegen (1)"; 1117 [id="node_1117" labelType="html" label="MapPartitionsRDD [1117] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2664 { id="cluster_2664"; isCluster="true"; label="map"; 1119 [id="node_1119" labelType="html" label="Delta Source Snapshot #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001114/stream-10000001114-1/_delta_log [1119] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2665 { id="cluster_2665"; isCluster="true"; label="WholeStageCodegen (1)"; 1120 [id="node_1120" labelType="html" label="MapPartitionsRDD [1120] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2667 { id="cluster_2667"; isCluster="true"; label="mapPartitionsInternal"; 1121 [id="node_1121" labelType="html" label="MapPartitionsRDD [1121] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_2668 { id="cluster_2668"; isCluster="true"; label="map"; 1122 [id="node_1122" labelType="html" label="MapPartitionsRDD [1122] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 1110->1111; 1111->1112; 1112->1113; 1113->1114; 1114->1115; 1115->1116; 1116->1117; 1117->1118; 1118->1119; 1119->1120; 1120->1121; 1121->1122; }

1109,1110

1119

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
356	tenants-pool-562	stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 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) 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/19 17:56:26	47 ms	1/1
355	tenants-pool-562	stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 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) 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/19 17:56:26	0.6 s	50/50	1485.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

356

tenants-pool-562

stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 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)
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/19 17:56:26

47 ms

1/1

355

tenants-pool-562

stream-10000001114-1 id = 09e10c7b-cd5f-4b13-8cb9-3bc8e526c000 runId = a8c33753-89a2-44e3-8dfb-1898d4a2933a batch = 0 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)
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/19 17:56:26

0.6 s

50/50

1485.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
354	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) 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)	Unknown	Unknown	0/1

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

354

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)
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)

Unknown

0/1

Page: