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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:37
Duration: 0.7 s
Associated SQL Query: 846
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_3977"; subgraph graph_stage_3977 { id="graph_stage_3977"; isCluster="true"; label="Stage 3977 (skipped)"; subgraph cluster_27487 { id="cluster_27487"; isCluster="true"; label="LocalTableScan"; 10210 [id="node_10210" labelType="html" label="ParallelCollectionRDD [10210] start at FileStorageAdapterImpl.java:177}"]; 10211 [id="node_10211" labelType="html" label="MapPartitionsRDD [10211] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27486 { id="cluster_27486"; isCluster="true"; label="Exchange"; 10212 [id="node_10212" labelType="html" label="MapPartitionsRDD [10212] start at FileStorageAdapterImpl.java:177}"]; } } 10210->10211; 10211->10212; }

digraph G { id="graph_3978"; subgraph graph_stage_3978 { id="graph_stage_3978"; isCluster="true"; label="Stage 3978 (skipped)"; subgraph cluster_27490 { id="cluster_27490"; isCluster="true"; label="LocalTableScan"; 10204 [id="node_10204" labelType="html" label="ParallelCollectionRDD [10204] start at FileStorageAdapterImpl.java:177}"]; 10206 [id="node_10206" labelType="html" label="MapPartitionsRDD [10206] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27489 { id="cluster_27489"; isCluster="true"; label="Exchange"; 10207 [id="node_10207" labelType="html" label="MapPartitionsRDD [10207] start at FileStorageAdapterImpl.java:177}"]; } } 10204->10206; 10206->10207; }

digraph G { id="graph_3979"; subgraph graph_stage_3979 { id="graph_stage_3979"; isCluster="true"; label="Stage 3979 (skipped)"; subgraph cluster_27503 { id="cluster_27503"; isCluster="true"; label="AQEShuffleRead"; 10213 [id="node_10213" labelType="html" label="ShuffledRowRDD [10213] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27500 { id="cluster_27500"; isCluster="true"; label="WholeStageCodegen (1)"; 10214 [id="node_10214" labelType="html" label="MapPartitionsRDD [10214] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27508 { id="cluster_27508"; isCluster="true"; label="AQEShuffleRead"; 10215 [id="node_10215" labelType="html" label="ShuffledRowRDD [10215] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27505 { id="cluster_27505"; isCluster="true"; label="WholeStageCodegen (2)"; 10216 [id="node_10216" labelType="html" label="MapPartitionsRDD [10216] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27496 { id="cluster_27496"; isCluster="true"; label="WholeStageCodegen (3)"; 10217 [id="node_10217" labelType="html" label="ZippedPartitionsRDD2 [10217] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10218 [id="node_10218" labelType="html" label="MapPartitionsRDD [10218] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27495 { id="cluster_27495"; isCluster="true"; label="Exchange"; 10219 [id="node_10219" labelType="html" label="MapPartitionsRDD [10219] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10213->10214; 10215->10216; 10214->10217; 10216->10217; 10217->10218; 10218->10219; }

10212,10213

10207,10215

digraph G { id="graph_3980"; subgraph graph_stage_3980 { id="graph_stage_3980"; isCluster="true"; label="Stage 3980 (skipped)"; subgraph cluster_27493 { id="cluster_27493"; isCluster="true"; label="LocalTableScan"; 10205 [id="node_10205" labelType="html" label="ParallelCollectionRDD [10205] start at FileStorageAdapterImpl.java:177}"]; 10208 [id="node_10208" labelType="html" label="MapPartitionsRDD [10208] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27492 { id="cluster_27492"; isCluster="true"; label="Exchange"; 10209 [id="node_10209" labelType="html" label="MapPartitionsRDD [10209] start at FileStorageAdapterImpl.java:177}"]; } } 10205->10208; 10208->10209; }

digraph G { id="graph_3981"; subgraph graph_stage_3981 { id="graph_stage_3981"; isCluster="true"; label="Stage 3981"; subgraph cluster_27518 { id="cluster_27518"; isCluster="true"; label="AQEShuffleRead"; 10220 [id="node_10220" labelType="html" label="ShuffledRowRDD [10220] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27515 { id="cluster_27515"; isCluster="true"; label="WholeStageCodegen (4)"; 10221 [id="node_10221" labelType="html" label="MapPartitionsRDD [10221] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27523 { id="cluster_27523"; isCluster="true"; label="AQEShuffleRead"; 10222 [id="node_10222" labelType="html" label="ShuffledRowRDD [10222] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27520 { id="cluster_27520"; isCluster="true"; label="WholeStageCodegen (5)"; 10223 [id="node_10223" labelType="html" label="MapPartitionsRDD [10223] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27510 { id="cluster_27510"; isCluster="true"; label="WholeStageCodegen (6)"; 10224 [id="node_10224" labelType="html" label="ZippedPartitionsRDD2 [10224] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10225 [id="node_10225" labelType="html" label="MapPartitionsRDD [10225] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27509 { id="cluster_27509"; isCluster="true"; label="WriteFiles"; 10226 [id="node_10226" labelType="html" label="MapPartitionsRDD [10226] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10220->10221; 10222->10223; 10221->10224; 10223->10224; 10224->10225; 10225->10226; }

10219,10220

10209,10222

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3981	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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/10 09:41:37	0.7 s	1/1		36.5 KiB	8.4 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3981

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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: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/10 09:41:37

0.7 s

1/1

36.5 KiB

8.4 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
3980	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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/25
3979	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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
3978	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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/25
3977	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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: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/25

Page: