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

Status: SUCCEEDED
Submitted: 2026/03/21 01:21:43
Duration: 0.8 s
Associated SQL Query: 3655
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_120372"; subgraph graph_stage_120372 { id="graph_stage_120372"; isCluster="true"; label="Stage 120372 (skipped)"; subgraph cluster_150290 { id="cluster_150290"; isCluster="true"; label="LocalTableScan"; 58006 [id="node_58006" labelType="html" label="ParallelCollectionRDD [58006] start at FileStorageAdapterImpl.java:171}"]; 58008 [id="node_58008" labelType="html" label="MapPartitionsRDD [58008] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150288 { id="cluster_150288"; isCluster="true"; label="Exchange"; 58010 [id="node_58010" labelType="html" label="MapPartitionsRDD [58010] start at FileStorageAdapterImpl.java:171}"]; } } 58006->58008; 58008->58010; }

digraph G { id="graph_120373"; subgraph graph_stage_120373 { id="graph_stage_120373"; isCluster="true"; label="Stage 120373 (skipped)"; subgraph cluster_150289 { id="cluster_150289"; isCluster="true"; label="LocalTableScan"; 58012 [id="node_58012" labelType="html" label="ParallelCollectionRDD [58012] start at FileStorageAdapterImpl.java:171}"]; 58013 [id="node_58013" labelType="html" label="MapPartitionsRDD [58013] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150286 { id="cluster_150286"; isCluster="true"; label="Exchange"; 58014 [id="node_58014" labelType="html" label="MapPartitionsRDD [58014] start at FileStorageAdapterImpl.java:171}"]; } } 58012->58013; 58013->58014; }

digraph G { id="graph_120374"; subgraph graph_stage_120374 { id="graph_stage_120374"; isCluster="true"; label="Stage 120374 (skipped)"; subgraph cluster_150303 { id="cluster_150303"; isCluster="true"; label="AQEShuffleRead"; 58015 [id="node_58015" labelType="html" label="ShuffledRowRDD [58015] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150300 { id="cluster_150300"; isCluster="true"; label="WholeStageCodegen (1)"; 58016 [id="node_58016" labelType="html" label="MapPartitionsRDD [58016] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150308 { id="cluster_150308"; isCluster="true"; label="AQEShuffleRead"; 58017 [id="node_58017" labelType="html" label="ShuffledRowRDD [58017] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150305 { id="cluster_150305"; isCluster="true"; label="WholeStageCodegen (2)"; 58018 [id="node_58018" labelType="html" label="MapPartitionsRDD [58018] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150296 { id="cluster_150296"; isCluster="true"; label="WholeStageCodegen (3)"; 58019 [id="node_58019" labelType="html" label="ZippedPartitionsRDD2 [58019] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 58020 [id="node_58020" labelType="html" label="MapPartitionsRDD [58020] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150295 { id="cluster_150295"; isCluster="true"; label="Exchange"; 58021 [id="node_58021" labelType="html" label="MapPartitionsRDD [58021] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 58015->58016; 58017->58018; 58016->58019; 58018->58019; 58019->58020; 58020->58021; }

58014,58015

58010,58017

digraph G { id="graph_120375"; subgraph graph_stage_120375 { id="graph_stage_120375"; isCluster="true"; label="Stage 120375 (skipped)"; subgraph cluster_150293 { id="cluster_150293"; isCluster="true"; label="LocalTableScan"; 58007 [id="node_58007" labelType="html" label="ParallelCollectionRDD [58007] start at FileStorageAdapterImpl.java:171}"]; 58009 [id="node_58009" labelType="html" label="MapPartitionsRDD [58009] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150292 { id="cluster_150292"; isCluster="true"; label="Exchange"; 58011 [id="node_58011" labelType="html" label="MapPartitionsRDD [58011] start at FileStorageAdapterImpl.java:171}"]; } } 58007->58009; 58009->58011; }

digraph G { id="graph_120376"; subgraph graph_stage_120376 { id="graph_stage_120376"; isCluster="true"; label="Stage 120376"; subgraph cluster_150318 { id="cluster_150318"; isCluster="true"; label="AQEShuffleRead"; 58022 [id="node_58022" labelType="html" label="ShuffledRowRDD [58022] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150315 { id="cluster_150315"; isCluster="true"; label="WholeStageCodegen (4)"; 58023 [id="node_58023" labelType="html" label="MapPartitionsRDD [58023] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150323 { id="cluster_150323"; isCluster="true"; label="AQEShuffleRead"; 58024 [id="node_58024" labelType="html" label="ShuffledRowRDD [58024] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150320 { id="cluster_150320"; isCluster="true"; label="WholeStageCodegen (5)"; 58025 [id="node_58025" labelType="html" label="MapPartitionsRDD [58025] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150310 { id="cluster_150310"; isCluster="true"; label="WholeStageCodegen (6)"; 58026 [id="node_58026" labelType="html" label="ZippedPartitionsRDD2 [58026] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 58027 [id="node_58027" labelType="html" label="MapPartitionsRDD [58027] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150309 { id="cluster_150309"; isCluster="true"; label="WriteFiles"; 58028 [id="node_58028" labelType="html" label="MapPartitionsRDD [58028] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 58022->58023; 58024->58025; 58023->58026; 58025->58026; 58026->58027; 58027->58028; }

58021,58022

58011,58024

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
120376	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 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) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:21:43	0.7 s	1/1		36.3 KiB	8.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

120376

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 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)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:21:43

0.7 s

1/1

36.3 KiB

8.2 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
120375	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) jdk.internal.reflect.GeneratedMethodAccessor1635.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/23
120374	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) jdk.internal.reflect.GeneratedMethodAccessor1635.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
120373	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) jdk.internal.reflect.GeneratedMethodAccessor1635.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/23
120372	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) jdk.internal.reflect.GeneratedMethodAccessor1635.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/23

Page: