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

Status: SUCCEEDED
Submitted: 2026/09/01 14:16:21
Duration: 0.7 s
Associated SQL Query: 41137
Job Group: e97f90ad-57e2-4862-afd3-46c7c1a84cab
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_241636"; subgraph graph_stage_241636 { id="graph_stage_241636"; isCluster="true"; label="Stage 241636 (skipped)"; subgraph cluster_1412355 { id="cluster_1412355"; isCluster="true"; label="LocalTableScan"; 540822 [id="node_540822" labelType="html" label="ParallelCollectionRDD [540822] start at FileStorageAdapterImpl.java:179}"]; 540824 [id="node_540824" labelType="html" label="MapPartitionsRDD [540824] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412354 { id="cluster_1412354"; isCluster="true"; label="Exchange"; 540825 [id="node_540825" labelType="html" label="MapPartitionsRDD [540825] start at FileStorageAdapterImpl.java:179}"]; } } 540822->540824; 540824->540825; }

digraph G { id="graph_241637"; subgraph graph_stage_241637 { id="graph_stage_241637"; isCluster="true"; label="Stage 241637 (skipped)"; subgraph cluster_1412352 { id="cluster_1412352"; isCluster="true"; label="LocalTableScan"; 540828 [id="node_540828" labelType="html" label="ParallelCollectionRDD [540828] start at FileStorageAdapterImpl.java:179}"]; 540829 [id="node_540829" labelType="html" label="MapPartitionsRDD [540829] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412351 { id="cluster_1412351"; isCluster="true"; label="Exchange"; 540830 [id="node_540830" labelType="html" label="MapPartitionsRDD [540830] start at FileStorageAdapterImpl.java:179}"]; } } 540828->540829; 540829->540830; }

digraph G { id="graph_241638"; subgraph graph_stage_241638 { id="graph_stage_241638"; isCluster="true"; label="Stage 241638 (skipped)"; subgraph cluster_1412368 { id="cluster_1412368"; isCluster="true"; label="AQEShuffleRead"; 540831 [id="node_540831" labelType="html" label="ShuffledRowRDD [540831] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412365 { id="cluster_1412365"; isCluster="true"; label="WholeStageCodegen (1)"; 540832 [id="node_540832" labelType="html" label="MapPartitionsRDD [540832] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412373 { id="cluster_1412373"; isCluster="true"; label="AQEShuffleRead"; 540833 [id="node_540833" labelType="html" label="ShuffledRowRDD [540833] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412370 { id="cluster_1412370"; isCluster="true"; label="WholeStageCodegen (2)"; 540834 [id="node_540834" labelType="html" label="MapPartitionsRDD [540834] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412361 { id="cluster_1412361"; isCluster="true"; label="WholeStageCodegen (3)"; 540835 [id="node_540835" labelType="html" label="ZippedPartitionsRDD2 [540835] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540836 [id="node_540836" labelType="html" label="MapPartitionsRDD [540836] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412360 { id="cluster_1412360"; isCluster="true"; label="Exchange"; 540837 [id="node_540837" labelType="html" label="MapPartitionsRDD [540837] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540831->540832; 540833->540834; 540832->540835; 540834->540835; 540835->540836; 540836->540837; }

540830,540831

540825,540833

digraph G { id="graph_241639"; subgraph graph_stage_241639 { id="graph_stage_241639"; isCluster="true"; label="Stage 241639 (skipped)"; subgraph cluster_1412358 { id="cluster_1412358"; isCluster="true"; label="LocalTableScan"; 540823 [id="node_540823" labelType="html" label="ParallelCollectionRDD [540823] start at FileStorageAdapterImpl.java:179}"]; 540826 [id="node_540826" labelType="html" label="MapPartitionsRDD [540826] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412357 { id="cluster_1412357"; isCluster="true"; label="Exchange"; 540827 [id="node_540827" labelType="html" label="MapPartitionsRDD [540827] start at FileStorageAdapterImpl.java:179}"]; } } 540823->540826; 540826->540827; }

digraph G { id="graph_241640"; subgraph graph_stage_241640 { id="graph_stage_241640"; isCluster="true"; label="Stage 241640"; subgraph cluster_1412383 { id="cluster_1412383"; isCluster="true"; label="AQEShuffleRead"; 540838 [id="node_540838" labelType="html" label="ShuffledRowRDD [540838] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412380 { id="cluster_1412380"; isCluster="true"; label="WholeStageCodegen (4)"; 540839 [id="node_540839" labelType="html" label="MapPartitionsRDD [540839] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412388 { id="cluster_1412388"; isCluster="true"; label="AQEShuffleRead"; 540840 [id="node_540840" labelType="html" label="ShuffledRowRDD [540840] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412385 { id="cluster_1412385"; isCluster="true"; label="WholeStageCodegen (5)"; 540841 [id="node_540841" labelType="html" label="MapPartitionsRDD [540841] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412375 { id="cluster_1412375"; isCluster="true"; label="WholeStageCodegen (6)"; 540842 [id="node_540842" labelType="html" label="ZippedPartitionsRDD2 [540842] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540843 [id="node_540843" labelType="html" label="MapPartitionsRDD [540843] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412374 { id="cluster_1412374"; isCluster="true"; label="WriteFiles"; 540844 [id="node_540844" labelType="html" label="MapPartitionsRDD [540844] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540838->540839; 540840->540841; 540839->540842; 540841->540842; 540842->540843; 540843->540844; }

540837,540838

540827,540840

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
241640	tenants-pool-506	stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 32 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/09/01 14:16:21	0.7 s	1/1		36.1 KiB	7.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

241640

tenants-pool-506

stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 32 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/09/01 14:16:21

0.7 s

1/1

36.1 KiB

7.2 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
241639	default	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)	Unknown	Unknown	0/20
241638	default	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)	Unknown	Unknown	0/1
241637	default	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)	Unknown	Unknown	0/20
241636	default	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)	Unknown	Unknown	0/20

Page: