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

Status: SUCCEEDED
Submitted: 2026/08/31 13:50:46
Duration: 1 s
Associated SQL Query: 32223
Job Group: a83ec7d1-e865-4e32-8433-c404e0daf43a
Completed Stages: 3

Enable zooming

digraph G { id="graph_190175"; subgraph graph_stage_190175 { id="graph_stage_190175"; isCluster="true"; label="Stage 190175"; 423327 [id="node_423327" labelType="html" label="SQLExecutionRDD [423327] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1106626 { id="cluster_1106626"; isCluster="true"; label="Scan parquet "; 423324 [id="node_423324" labelType="html" label="FileScanRDD [423324] start at FileStorageAdapterImpl.java:179}"]; 423325 [id="node_423325" labelType="html" label="MapPartitionsRDD [423325] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106623 { id="cluster_1106623"; isCluster="true"; label="WholeStageCodegen (1)"; 423326 [id="node_423326" labelType="html" label="MapPartitionsRDD [423326] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106630 { id="cluster_1106630"; isCluster="true"; label="WholeStageCodegen (1)"; 423328 [id="node_423328" labelType="html" label="MapPartitionsRDD [423328] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106629 { id="cluster_1106629"; isCluster="true"; label="Exchange"; 423329 [id="node_423329" labelType="html" label="MapPartitionsRDD [423329] start at FileStorageAdapterImpl.java:179}"]; } } 423324->423325; 423325->423326; 423326->423327; 423327->423328; 423328->423329; }

digraph G { id="graph_190176"; subgraph graph_stage_190176 { id="graph_stage_190176"; isCluster="true"; label="Stage 190176"; subgraph cluster_1106629 { id="cluster_1106629"; isCluster="true"; label="Exchange"; 423330 [id="node_423330" labelType="html" label="ShuffledRowRDD [423330] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106628 { id="cluster_1106628"; isCluster="true"; label="InMemoryTableScan"; 423331 [id="node_423331" labelType="html" label="MapPartitionsRDD [423331] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423332 [id="node_423332" labelType="html" label="Exchange hashpartitioning(product#6552500, plant#6552501, 30), REPARTITION_BY_NUM, [plan_id=29051203]\n+- *(1) Scan ExistingRDD[shardId#6552497,worklistShardItemId#6552498L,version#6552499,product#6552500,plant#6552501,periodStart#6552502,periodEnd#6552503,qty#6552504]\n [423332] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423333 [id="node_423333" labelType="html" label="MapPartitionsRDD [423333] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423334 [id="node_423334" labelType="html" label="MapPartitionsRDD [423334] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423335 [id="node_423335" labelType="html" label="MapPartitionsRDD [423335] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106627 { id="cluster_1106627"; isCluster="true"; label="CollectLimit"; 423336 [id="node_423336" labelType="html" label="MapPartitionsRDD [423336] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423337 [id="node_423337" labelType="html" label="MapPartitionsRDD [423337] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 423330->423331; 423331->423332; 423332->423333; 423333->423334; 423334->423335; 423335->423336; 423336->423337; }

423329,423330

423332

digraph G { id="graph_190177"; subgraph graph_stage_190177 { id="graph_stage_190177"; isCluster="true"; label="Stage 190177"; subgraph cluster_1106627 { id="cluster_1106627"; isCluster="true"; label="CollectLimit"; 423338 [id="node_423338" labelType="html" label="ShuffledRowRDD [423338] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423339 [id="node_423339" labelType="html" label="MapPartitionsRDD [423339] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106632 { id="cluster_1106632"; isCluster="true"; label="mapPartitionsInternal"; 423340 [id="node_423340" labelType="html" label="MapPartitionsRDD [423340] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 423338->423339; 423339->423340; }

423337,423338

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
190177	tenants-pool-506	stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:47	7 ms	1/1
190176	tenants-pool-506	stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:47	0.7 s	30/30	4.3 MiB	1860.0 B
190175	tenants-pool-506	stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:46	0.4 s	37/37		4.3 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

190177

tenants-pool-506

stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:47

7 ms

1/1

190176

tenants-pool-506

stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:47

0.7 s

30/30

4.3 MiB

1860.0 B

190175

tenants-pool-506

stream-10000000532-3 id = bd1bdf58-6513-4e3f-a106-a3f904205105 runId = a83ec7d1-e865-4e32-8433-c404e0daf43a batch = 19 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 13:50:46

0.4 s

37/37

4.3 MiB

Page: