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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:53
Duration: 0.2 s
Job Group: 49208f80-235d-43ef-8cae-50261bfa1fbb
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { id="graph_48"; subgraph graph_stage_48 { id="graph_stage_48"; isCluster="true"; label="Stage 48 (skipped)"; subgraph cluster_360 { id="cluster_360"; isCluster="true"; label="Scan json "; 150 [id="node_150" labelType="html" label="FileScanRDD [150] start at FileStorageAdapterImpl.java:171}"]; 151 [id="node_151" labelType="html" label="MapPartitionsRDD [151] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_357 { id="cluster_357"; isCluster="true"; label="WholeStageCodegen (1)"; 152 [id="node_152" labelType="html" label="MapPartitionsRDD [152] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_356 { id="cluster_356"; isCluster="true"; label="Exchange"; 153 [id="node_153" labelType="html" label="MapPartitionsRDD [153] start at FileStorageAdapterImpl.java:171}"]; } } 150->151; 151->152; 152->153; }

digraph G { id="graph_49"; subgraph graph_stage_49 { id="graph_stage_49"; isCluster="true"; label="Stage 49"; 159 [id="node_159" labelType="html" label="SQLExecutionRDD [159] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_356 { id="cluster_356"; isCluster="true"; label="Exchange"; 154 [id="node_154" labelType="html" label="ShuffledRowRDD [154] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_352 { id="cluster_352"; isCluster="true"; label="WholeStageCodegen (2)"; 155 [id="node_155" labelType="html" label="MapPartitionsRDD [155] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_351 { id="cluster_351"; isCluster="true"; label="DeserializeToObject"; 156 [id="node_156" labelType="html" label="MapPartitionsRDD [156] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_350 { id="cluster_350"; isCluster="true"; label="MapPartitions"; 157 [id="node_157" labelType="html" label="MapPartitionsRDD [157] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_347 { id="cluster_347"; isCluster="true"; label="WholeStageCodegen (3)"; 158 [id="node_158" labelType="html" label="MapPartitionsRDD [158] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_361 { id="cluster_361"; isCluster="true"; label="map"; 160 [id="node_160" 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/10000000096/stream-10000000096-1/_delta_log [160] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_367 { id="cluster_367"; isCluster="true"; label="WholeStageCodegen (1)"; 161 [id="node_161" labelType="html" label="MapPartitionsRDD [161] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_366 { id="cluster_366"; isCluster="true"; label="Exchange"; 165 [id="node_165" labelType="html" label="MapPartitionsRDD [165] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 154->155; 155->156; 156->157; 157->158; 158->159; 159->160; 160->161; 161->165; }

153,154

160

digraph G { id="graph_50"; subgraph graph_stage_50 { id="graph_stage_50"; isCluster="true"; label="Stage 50"; 169 [id="node_169" labelType="html" label="SQLExecutionRDD [169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 174 [id="node_174" labelType="html" label="SQLExecutionRDD [174] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_366 { id="cluster_366"; isCluster="true"; label="Exchange"; 166 [id="node_166" labelType="html" label="ShuffledRowRDD [166] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_363 { id="cluster_363"; isCluster="true"; label="WholeStageCodegen (2)"; 167 [id="node_167" labelType="html" label="MapPartitionsRDD [167] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_362 { id="cluster_362"; isCluster="true"; label="DeserializeToObject"; 168 [id="node_168" labelType="html" label="MapPartitionsRDD [168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_386 { id="cluster_386"; isCluster="true"; label="mapPartitions"; 170 [id="node_170" labelType="html" label="MapPartitionsRDD [170] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_387 { id="cluster_387"; isCluster="true"; label="zipWithIndex"; 171 [id="node_171" labelType="html" label="ZippedWithIndexRDD [171] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_392 { id="cluster_392"; isCluster="true"; label="Scan"; 172 [id="node_172" labelType="html" label="MapPartitionsRDD [172] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_388 { id="cluster_388"; isCluster="true"; label="WholeStageCodegen (1)"; 173 [id="node_173" labelType="html" label="MapPartitionsRDD [173] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_393 { id="cluster_393"; isCluster="true"; label="map"; 175 [id="node_175" 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/10000000096/stream-10000000096-1/_delta_log [175] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_394 { id="cluster_394"; isCluster="true"; label="WholeStageCodegen (1)"; 176 [id="node_176" labelType="html" label="MapPartitionsRDD [176] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_396 { id="cluster_396"; isCluster="true"; label="mapPartitionsInternal"; 177 [id="node_177" labelType="html" label="MapPartitionsRDD [177] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_397 { id="cluster_397"; isCluster="true"; label="map"; 178 [id="node_178" labelType="html" label="MapPartitionsRDD [178] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 166->167; 167->168; 168->169; 169->170; 170->171; 171->172; 172->173; 173->174; 174->175; 175->176; 176->177; 177->178; }

165,166

175

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
50	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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 10:33:53	27 ms	1/1
49	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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/10000000096/stream-10000000096-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 10:33:53	0.1 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-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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 10:33:53

27 ms

1/1

tenants-pool-286

stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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/10000000096/stream-10000000096-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 10:33:53

0.1 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
48	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: