crp-order-quantity-kpi-service

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:19
Duration: 0.4 s
Job Group: 838a6e4f-fcfd-48b4-8e86-83234309cbb3
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_104 { id="cluster_104"; isCluster="true"; label="Scan json "; 39 [id="node_39" labelType="html" label="FileScanRDD [39] start at FileStorageAdapterImpl.java:171}"]; 40 [id="node_40" labelType="html" label="MapPartitionsRDD [40] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_101 { id="cluster_101"; isCluster="true"; label="WholeStageCodegen (1)"; 41 [id="node_41" labelType="html" label="MapPartitionsRDD [41] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100 { id="cluster_100"; isCluster="true"; label="Exchange"; 42 [id="node_42" labelType="html" label="MapPartitionsRDD [42] start at FileStorageAdapterImpl.java:171}"]; } } 39->40; 40->41; 41->42; }

digraph G { id="graph_15"; subgraph graph_stage_15 { id="graph_stage_15"; isCluster="true"; label="Stage 15"; 48 [id="node_48" labelType="html" label="SQLExecutionRDD [48] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_100 { id="cluster_100"; isCluster="true"; label="Exchange"; 43 [id="node_43" labelType="html" label="ShuffledRowRDD [43] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_96 { id="cluster_96"; isCluster="true"; label="WholeStageCodegen (2)"; 44 [id="node_44" labelType="html" label="MapPartitionsRDD [44] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_95 { id="cluster_95"; isCluster="true"; label="DeserializeToObject"; 45 [id="node_45" labelType="html" label="MapPartitionsRDD [45] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_94 { id="cluster_94"; isCluster="true"; label="MapPartitions"; 46 [id="node_46" labelType="html" label="MapPartitionsRDD [46] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_91 { id="cluster_91"; isCluster="true"; label="WholeStageCodegen (3)"; 47 [id="node_47" labelType="html" label="MapPartitionsRDD [47] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_105 { id="cluster_105"; isCluster="true"; label="map"; 49 [id="node_49" labelType="html" label="Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log [49] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111 { id="cluster_111"; isCluster="true"; label="WholeStageCodegen (1)"; 50 [id="node_50" labelType="html" label="MapPartitionsRDD [50] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110 { id="cluster_110"; isCluster="true"; label="Exchange"; 54 [id="node_54" labelType="html" label="MapPartitionsRDD [54] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 43->44; 44->45; 45->46; 46->47; 47->48; 48->49; 49->50; 50->54; }

42,43

digraph G { id="graph_16"; subgraph graph_stage_16 { id="graph_stage_16"; isCluster="true"; label="Stage 16"; 58 [id="node_58" labelType="html" label="SQLExecutionRDD [58] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 63 [id="node_63" labelType="html" label="SQLExecutionRDD [63] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_110 { id="cluster_110"; isCluster="true"; label="Exchange"; 55 [id="node_55" labelType="html" label="ShuffledRowRDD [55] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_107 { id="cluster_107"; isCluster="true"; label="WholeStageCodegen (2)"; 56 [id="node_56" labelType="html" label="MapPartitionsRDD [56] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_106 { id="cluster_106"; isCluster="true"; label="DeserializeToObject"; 57 [id="node_57" labelType="html" label="MapPartitionsRDD [57] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130 { id="cluster_130"; isCluster="true"; label="mapPartitions"; 59 [id="node_59" labelType="html" label="MapPartitionsRDD [59] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131 { id="cluster_131"; isCluster="true"; label="zipWithIndex"; 60 [id="node_60" labelType="html" label="ZippedWithIndexRDD [60] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136 { id="cluster_136"; isCluster="true"; label="Scan"; 61 [id="node_61" labelType="html" label="MapPartitionsRDD [61] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_132 { id="cluster_132"; isCluster="true"; label="WholeStageCodegen (1)"; 62 [id="node_62" labelType="html" label="MapPartitionsRDD [62] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137 { id="cluster_137"; isCluster="true"; label="map"; 64 [id="node_64" labelType="html" label="Delta Source Snapshot #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log [64] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138 { id="cluster_138"; isCluster="true"; label="WholeStageCodegen (1)"; 65 [id="node_65" labelType="html" label="MapPartitionsRDD [65] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140 { id="cluster_140"; isCluster="true"; label="mapPartitionsInternal"; 66 [id="node_66" labelType="html" label="MapPartitionsRDD [66] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141 { id="cluster_141"; isCluster="true"; label="map"; 67 [id="node_67" labelType="html" label="MapPartitionsRDD [67] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 55->56; 56->57; 57->58; 58->59; 59->60; 60->61; 61->62; 62->63; 63->64; 64->65; 65->66; 66->67; }

54,55

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
16	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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/02/06 06:55:20	0.2 s	1/1
15	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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/02/06 06:55:19	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-286

stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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/02/06 06:55:20

0.2 s

1/1

tenants-pool-286

stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details

RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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/02/06 06:55:19

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:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) 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:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
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)