crp-order-quantity-kpi-service

Status: SUCCEEDED
Submitted: 2026/04/10 15:02:22
Duration: 0.4 s
Job Group: d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { id="graph_14"; subgraph graph_stage_14 { id="graph_stage_14"; isCluster="true"; label="Stage 14 (skipped)"; subgraph cluster_101 { id="cluster_101"; isCluster="true"; label="Scan json "; 34 [id="node_34" labelType="html" label="FileScanRDD [34] start at FileStorageAdapterImpl.java:174}"]; 35 [id="node_35" labelType="html" label="MapPartitionsRDD [35] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_98 { id="cluster_98"; isCluster="true"; label="WholeStageCodegen (1)"; 36 [id="node_36" labelType="html" label="MapPartitionsRDD [36] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_97 { id="cluster_97"; isCluster="true"; label="Exchange"; 37 [id="node_37" labelType="html" label="MapPartitionsRDD [37] start at FileStorageAdapterImpl.java:174}"]; } } 34->35; 35->36; 36->37; }

digraph G { id="graph_15"; subgraph graph_stage_15 { id="graph_stage_15"; isCluster="true"; label="Stage 15"; 43 [id="node_43" labelType="html" label="SQLExecutionRDD [43] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_97 { id="cluster_97"; isCluster="true"; label="Exchange"; 38 [id="node_38" labelType="html" label="ShuffledRowRDD [38] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_93 { id="cluster_93"; isCluster="true"; label="WholeStageCodegen (2)"; 39 [id="node_39" labelType="html" label="MapPartitionsRDD [39] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_92 { id="cluster_92"; isCluster="true"; label="DeserializeToObject"; 40 [id="node_40" labelType="html" label="MapPartitionsRDD [40] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_91 { id="cluster_91"; isCluster="true"; label="MapPartitions"; 41 [id="node_41" labelType="html" label="MapPartitionsRDD [41] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_88 { id="cluster_88"; isCluster="true"; label="WholeStageCodegen (3)"; 42 [id="node_42" labelType="html" label="MapPartitionsRDD [42] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_102 { id="cluster_102"; isCluster="true"; label="map"; 44 [id="node_44" labelType="html" label="Delta Table State #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000279/stream-10000000279-1/_delta_log [44] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_108 { id="cluster_108"; isCluster="true"; label="WholeStageCodegen (1)"; 45 [id="node_45" labelType="html" label="MapPartitionsRDD [45] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_107 { id="cluster_107"; isCluster="true"; label="Exchange"; 49 [id="node_49" labelType="html" label="MapPartitionsRDD [49] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 38->39; 39->40; 40->41; 41->42; 42->43; 43->44; 44->45; 45->49; }

37,38

digraph G { id="graph_16"; subgraph graph_stage_16 { id="graph_stage_16"; isCluster="true"; label="Stage 16"; 53 [id="node_53" labelType="html" label="SQLExecutionRDD [53] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 58 [id="node_58" labelType="html" label="SQLExecutionRDD [58] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_107 { id="cluster_107"; isCluster="true"; label="Exchange"; 50 [id="node_50" labelType="html" label="ShuffledRowRDD [50] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_104 { id="cluster_104"; isCluster="true"; label="WholeStageCodegen (2)"; 51 [id="node_51" labelType="html" label="MapPartitionsRDD [51] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_103 { id="cluster_103"; isCluster="true"; label="DeserializeToObject"; 52 [id="node_52" labelType="html" label="MapPartitionsRDD [52] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_127 { id="cluster_127"; isCluster="true"; label="mapPartitions"; 54 [id="node_54" labelType="html" label="MapPartitionsRDD [54] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_128 { id="cluster_128"; isCluster="true"; label="zipWithIndex"; 55 [id="node_55" labelType="html" label="ZippedWithIndexRDD [55] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_133 { id="cluster_133"; isCluster="true"; label="Scan"; 56 [id="node_56" labelType="html" label="MapPartitionsRDD [56] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_129 { id="cluster_129"; isCluster="true"; label="WholeStageCodegen (1)"; 57 [id="node_57" labelType="html" label="MapPartitionsRDD [57] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_134 { id="cluster_134"; isCluster="true"; label="map"; 59 [id="node_59" labelType="html" label="Delta Source Snapshot #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000279/stream-10000000279-1/_delta_log [59] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_135 { id="cluster_135"; isCluster="true"; label="WholeStageCodegen (1)"; 60 [id="node_60" labelType="html" label="MapPartitionsRDD [60] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_137 { id="cluster_137"; isCluster="true"; label="mapPartitionsInternal"; 61 [id="node_61" labelType="html" label="MapPartitionsRDD [61] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_138 { id="cluster_138"; isCluster="true"; label="map"; 62 [id="node_62" labelType="html" label="MapPartitionsRDD [62] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 50->51; 51->52; 52->53; 53->54; 54->55; 55->56; 56->57; 57->58; 58->59; 59->60; 60->61; 61->62; }

49,50

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
16	tenants-pool-768	stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 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/04/10 15:02:22	0.2 s	1/1
15	tenants-pool-768	stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 start at FileStorageAdapterImpl.java:174 +details RDD: Delta Table State #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000279/stream-10000000279-1/_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) 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/04/10 15:02:22	0.2 s	50/50	1485.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-768

stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 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/04/10 15:02:22

0.2 s

1/1

tenants-pool-768

stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 start at FileStorageAdapterImpl.java:174 +details

RDD: Delta Table State #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000279/stream-10000000279-1/_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)
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/04/10 15:02:22

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

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

Details for Job 9

Completed Stages (2)

Skipped Stages (1)