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

Status: SUCCEEDED
Submitted: 2026/03/21 20:16:21
Duration: 0.6 s
Associated SQL Query: 3921
Job Group: 325a8812-9963-4820-9b32-c1b224f207b8
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_129864"; subgraph graph_stage_129864 { id="graph_stage_129864"; isCluster="true"; label="Stage 129864 (skipped)"; subgraph cluster_160911 { id="cluster_160911"; isCluster="true"; label="LocalTableScan"; 62308 [id="node_62308" labelType="html" label="ParallelCollectionRDD [62308] start at FileStorageAdapterImpl.java:171}"]; 62310 [id="node_62310" labelType="html" label="MapPartitionsRDD [62310] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160910 { id="cluster_160910"; isCluster="true"; label="Exchange"; 62312 [id="node_62312" labelType="html" label="MapPartitionsRDD [62312] start at FileStorageAdapterImpl.java:171}"]; } } 62308->62310; 62310->62312; }

digraph G { id="graph_129865"; subgraph graph_stage_129865 { id="graph_stage_129865"; isCluster="true"; label="Stage 129865 (skipped)"; subgraph cluster_160908 { id="cluster_160908"; isCluster="true"; label="LocalTableScan"; 62314 [id="node_62314" labelType="html" label="ParallelCollectionRDD [62314] start at FileStorageAdapterImpl.java:171}"]; 62315 [id="node_62315" labelType="html" label="MapPartitionsRDD [62315] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160907 { id="cluster_160907"; isCluster="true"; label="Exchange"; 62316 [id="node_62316" labelType="html" label="MapPartitionsRDD [62316] start at FileStorageAdapterImpl.java:171}"]; } } 62314->62315; 62315->62316; }

digraph G { id="graph_129866"; subgraph graph_stage_129866 { id="graph_stage_129866"; isCluster="true"; label="Stage 129866 (skipped)"; subgraph cluster_160924 { id="cluster_160924"; isCluster="true"; label="AQEShuffleRead"; 62317 [id="node_62317" labelType="html" label="ShuffledRowRDD [62317] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160921 { id="cluster_160921"; isCluster="true"; label="WholeStageCodegen (1)"; 62318 [id="node_62318" labelType="html" label="MapPartitionsRDD [62318] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160929 { id="cluster_160929"; isCluster="true"; label="AQEShuffleRead"; 62319 [id="node_62319" labelType="html" label="ShuffledRowRDD [62319] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160926 { id="cluster_160926"; isCluster="true"; label="WholeStageCodegen (2)"; 62320 [id="node_62320" labelType="html" label="MapPartitionsRDD [62320] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160917 { id="cluster_160917"; isCluster="true"; label="WholeStageCodegen (3)"; 62321 [id="node_62321" labelType="html" label="ZippedPartitionsRDD2 [62321] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 62322 [id="node_62322" labelType="html" label="MapPartitionsRDD [62322] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160916 { id="cluster_160916"; isCluster="true"; label="Exchange"; 62323 [id="node_62323" labelType="html" label="MapPartitionsRDD [62323] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 62317->62318; 62319->62320; 62318->62321; 62320->62321; 62321->62322; 62322->62323; }

62316,62317

62312,62319

digraph G { id="graph_129867"; subgraph graph_stage_129867 { id="graph_stage_129867"; isCluster="true"; label="Stage 129867 (skipped)"; subgraph cluster_160914 { id="cluster_160914"; isCluster="true"; label="LocalTableScan"; 62309 [id="node_62309" labelType="html" label="ParallelCollectionRDD [62309] start at FileStorageAdapterImpl.java:171}"]; 62311 [id="node_62311" labelType="html" label="MapPartitionsRDD [62311] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160913 { id="cluster_160913"; isCluster="true"; label="Exchange"; 62313 [id="node_62313" labelType="html" label="MapPartitionsRDD [62313] start at FileStorageAdapterImpl.java:171}"]; } } 62309->62311; 62311->62313; }

digraph G { id="graph_129868"; subgraph graph_stage_129868 { id="graph_stage_129868"; isCluster="true"; label="Stage 129868"; subgraph cluster_160939 { id="cluster_160939"; isCluster="true"; label="AQEShuffleRead"; 62324 [id="node_62324" labelType="html" label="ShuffledRowRDD [62324] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160936 { id="cluster_160936"; isCluster="true"; label="WholeStageCodegen (4)"; 62325 [id="node_62325" labelType="html" label="MapPartitionsRDD [62325] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160944 { id="cluster_160944"; isCluster="true"; label="AQEShuffleRead"; 62326 [id="node_62326" labelType="html" label="ShuffledRowRDD [62326] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160941 { id="cluster_160941"; isCluster="true"; label="WholeStageCodegen (5)"; 62327 [id="node_62327" labelType="html" label="MapPartitionsRDD [62327] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160931 { id="cluster_160931"; isCluster="true"; label="WholeStageCodegen (6)"; 62328 [id="node_62328" labelType="html" label="ZippedPartitionsRDD2 [62328] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 62329 [id="node_62329" labelType="html" label="MapPartitionsRDD [62329] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_160930 { id="cluster_160930"; isCluster="true"; label="WriteFiles"; 62330 [id="node_62330" labelType="html" label="MapPartitionsRDD [62330] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 62324->62325; 62326->62327; 62325->62328; 62327->62328; 62328->62329; 62329->62330; }

62323,62324

62313,62326

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
129868	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 14 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 20:16:21	0.6 s	1/1		35.8 KiB	7.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

129868

tenants-pool-780

stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 14 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 20:16:21

0.6 s

1/1

35.8 KiB

7.5 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
129867	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/21
129866	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
129865	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/21
129864	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/21

Page: