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

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:22
Duration: 0.9 s
Associated SQL Query: 14
Job Group: 838a6e4f-fcfd-48b4-8e86-83234309cbb3
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_29"; subgraph graph_stage_29 { id="graph_stage_29"; isCluster="true"; label="Stage 29 (skipped)"; subgraph cluster_199 { id="cluster_199"; isCluster="true"; label="LocalTableScan"; 88 [id="node_88" labelType="html" label="ParallelCollectionRDD [88] start at FileStorageAdapterImpl.java:171}"]; 90 [id="node_90" labelType="html" label="MapPartitionsRDD [90] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_198 { id="cluster_198"; isCluster="true"; label="Exchange"; 91 [id="node_91" labelType="html" label="MapPartitionsRDD [91] start at FileStorageAdapterImpl.java:171}"]; } } 88->90; 90->91; }

digraph G { id="graph_30"; subgraph graph_stage_30 { id="graph_stage_30"; isCluster="true"; label="Stage 30 (skipped)"; subgraph cluster_196 { id="cluster_196"; isCluster="true"; label="LocalTableScan"; 94 [id="node_94" labelType="html" label="ParallelCollectionRDD [94] start at FileStorageAdapterImpl.java:171}"]; 95 [id="node_95" labelType="html" label="MapPartitionsRDD [95] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_195 { id="cluster_195"; isCluster="true"; label="Exchange"; 96 [id="node_96" labelType="html" label="MapPartitionsRDD [96] start at FileStorageAdapterImpl.java:171}"]; } } 94->95; 95->96; }

digraph G { id="graph_31"; subgraph graph_stage_31 { id="graph_stage_31"; isCluster="true"; label="Stage 31 (skipped)"; subgraph cluster_212 { id="cluster_212"; isCluster="true"; label="AQEShuffleRead"; 97 [id="node_97" labelType="html" label="ShuffledRowRDD [97] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_209 { id="cluster_209"; isCluster="true"; label="WholeStageCodegen (1)"; 98 [id="node_98" labelType="html" label="MapPartitionsRDD [98] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_217 { id="cluster_217"; isCluster="true"; label="AQEShuffleRead"; 99 [id="node_99" labelType="html" label="ShuffledRowRDD [99] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_214 { id="cluster_214"; isCluster="true"; label="WholeStageCodegen (2)"; 100 [id="node_100" labelType="html" label="MapPartitionsRDD [100] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_205 { id="cluster_205"; isCluster="true"; label="WholeStageCodegen (3)"; 101 [id="node_101" labelType="html" label="ZippedPartitionsRDD2 [101] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 102 [id="node_102" labelType="html" label="MapPartitionsRDD [102] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_204 { id="cluster_204"; isCluster="true"; label="Exchange"; 103 [id="node_103" labelType="html" label="MapPartitionsRDD [103] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 97->98; 99->100; 98->101; 100->101; 101->102; 102->103; }

96,97

91,99

digraph G { id="graph_32"; subgraph graph_stage_32 { id="graph_stage_32"; isCluster="true"; label="Stage 32 (skipped)"; subgraph cluster_202 { id="cluster_202"; isCluster="true"; label="LocalTableScan"; 89 [id="node_89" labelType="html" label="ParallelCollectionRDD [89] start at FileStorageAdapterImpl.java:171}"]; 92 [id="node_92" labelType="html" label="MapPartitionsRDD [92] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_201 { id="cluster_201"; isCluster="true"; label="Exchange"; 93 [id="node_93" labelType="html" label="MapPartitionsRDD [93] start at FileStorageAdapterImpl.java:171}"]; } } 89->92; 92->93; }

digraph G { id="graph_33"; subgraph graph_stage_33 { id="graph_stage_33"; isCluster="true"; label="Stage 33"; subgraph cluster_227 { id="cluster_227"; isCluster="true"; label="AQEShuffleRead"; 104 [id="node_104" labelType="html" label="ShuffledRowRDD [104] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_224 { id="cluster_224"; isCluster="true"; label="WholeStageCodegen (4)"; 105 [id="node_105" labelType="html" label="MapPartitionsRDD [105] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_232 { id="cluster_232"; isCluster="true"; label="AQEShuffleRead"; 106 [id="node_106" labelType="html" label="ShuffledRowRDD [106] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_229 { id="cluster_229"; isCluster="true"; label="WholeStageCodegen (5)"; 107 [id="node_107" labelType="html" label="MapPartitionsRDD [107] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_219 { id="cluster_219"; isCluster="true"; label="WholeStageCodegen (6)"; 108 [id="node_108" labelType="html" label="ZippedPartitionsRDD2 [108] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 109 [id="node_109" labelType="html" label="MapPartitionsRDD [109] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_218 { id="cluster_218"; isCluster="true"; label="WriteFiles"; 110 [id="node_110" labelType="html" label="MapPartitionsRDD [110] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 104->105; 106->107; 105->108; 107->108; 108->109; 109->110; }

103,104

93,106

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
33	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 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) 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: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/02/06 06:55:22	0.9 s	1/1		32.5 KiB	1446.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-286

stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 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)
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: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/02/06 06:55:22

0.9 s

1/1

32.5 KiB

1446.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
32	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) 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: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/4
31	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) 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: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
30	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) 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: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/4
29	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) 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: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/4

Page: