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

Status: SUCCEEDED
Submitted: 2026/08/31 14:14:44
Duration: 2 s
Associated SQL Query: 32392
Job Group: ea70e965-fb74-4f46-a423-d6f918b125d4
Completed Stages: 3

Enable zooming

digraph G { id="graph_190967"; subgraph graph_stage_190967 { id="graph_stage_190967"; isCluster="true"; label="Stage 190967"; subgraph cluster_1111919 { id="cluster_1111919"; isCluster="true"; label="Scan json "; 425479 [id="node_425479" labelType="html" label="FileScanRDD [425479] start at FileStorageAdapterImpl.java:179}"]; 425480 [id="node_425480" labelType="html" label="MapPartitionsRDD [425480] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111916 { id="cluster_1111916"; isCluster="true"; label="WholeStageCodegen (1)"; 425481 [id="node_425481" labelType="html" label="MapPartitionsRDD [425481] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111915 { id="cluster_1111915"; isCluster="true"; label="Exchange"; 425482 [id="node_425482" labelType="html" label="MapPartitionsRDD [425482] start at FileStorageAdapterImpl.java:179}"]; } } 425479->425480; 425480->425481; 425481->425482; }

digraph G { id="graph_190968"; subgraph graph_stage_190968 { id="graph_stage_190968"; isCluster="true"; label="Stage 190968"; 425488 [id="node_425488" labelType="html" label="SQLExecutionRDD [425488] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1111915 { id="cluster_1111915"; isCluster="true"; label="Exchange"; 425483 [id="node_425483" labelType="html" label="ShuffledRowRDD [425483] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111911 { id="cluster_1111911"; isCluster="true"; label="WholeStageCodegen (2)"; 425484 [id="node_425484" labelType="html" label="MapPartitionsRDD [425484] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111910 { id="cluster_1111910"; isCluster="true"; label="DeserializeToObject"; 425485 [id="node_425485" labelType="html" label="MapPartitionsRDD [425485] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111909 { id="cluster_1111909"; isCluster="true"; label="MapPartitions"; 425486 [id="node_425486" labelType="html" label="MapPartitionsRDD [425486] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111906 { id="cluster_1111906"; isCluster="true"; label="WholeStageCodegen (3)"; 425487 [id="node_425487" labelType="html" label="MapPartitionsRDD [425487] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111920 { id="cluster_1111920"; isCluster="true"; label="map"; 425489 [id="node_425489" labelType="html" label="Delta Table State #6 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-2/shardId=0_3_10000000532/_delta_log [425489] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111924 { id="cluster_1111924"; isCluster="true"; label="WholeStageCodegen (1)"; 425490 [id="node_425490" labelType="html" label="MapPartitionsRDD [425490] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111923 { id="cluster_1111923"; isCluster="true"; label="ObjectHashAggregate"; 425491 [id="node_425491" labelType="html" label="MapPartitionsRDD [425491] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111922 { id="cluster_1111922"; isCluster="true"; label="Exchange"; 425492 [id="node_425492" labelType="html" label="MapPartitionsRDD [425492] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425483->425484; 425484->425485; 425485->425486; 425486->425487; 425487->425488; 425488->425489; 425489->425490; 425490->425491; 425491->425492; }

425482,425483

425489

digraph G { id="graph_190969"; subgraph graph_stage_190969 { id="graph_stage_190969"; isCluster="true"; label="Stage 190969"; subgraph cluster_1111922 { id="cluster_1111922"; isCluster="true"; label="Exchange"; 425493 [id="node_425493" labelType="html" label="ShuffledRowRDD [425493] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111921 { id="cluster_1111921"; isCluster="true"; label="ObjectHashAggregate"; 425494 [id="node_425494" labelType="html" label="MapPartitionsRDD [425494] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111927 { id="cluster_1111927"; isCluster="true"; label="mapPartitionsInternal"; 425495 [id="node_425495" labelType="html" label="MapPartitionsRDD [425495] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425493->425494; 425494->425495; }

425492,425493

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
190969	tenants-pool-506	Delta: Delta: stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 17: Filtering files for query: Compute snapshot for version: 6 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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/31 14:14:46	75 ms	1/1	5.9 KiB
190968	tenants-pool-506	Delta: Delta: stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 17: Filtering files for query: Compute snapshot for version: 6 start at FileStorageAdapterImpl.java:179 +details RDD: Delta Table State #6 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-2/shardId=0_3_10000000532/_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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/31 14:14:45	1 s	50/50	96.1 KiB	5.9 KiB
190967	tenants-pool-506	Delta: Delta: stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 17: Filtering files for query: Compute snapshot for version: 6 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.GeneratedMethodAccessor984.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/31 14:14:44	0.5 s	7/7		96.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

190969

tenants-pool-506

Delta: Delta: stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 17: Filtering files for query: Compute snapshot for version: 6 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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/31 14:14:46

75 ms

1/1

5.9 KiB

190968

tenants-pool-506

RDD: Delta Table State #6 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-2/shardId=0_3_10000000532/_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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/31 14:14:45

1 s

50/50

96.1 KiB

5.9 KiB

190967

tenants-pool-506

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.GeneratedMethodAccessor984.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/31 14:14:44

0.5 s

7/7

96.1 KiB

Page: