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

Status: SUCCEEDED
Submitted: 2026/04/10 15:02:25
Duration: 2 s
Associated SQL Query: 13
Job Group: d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19
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_193 { id="cluster_193"; isCluster="true"; label="LocalTableScan"; 89 [id="node_89" labelType="html" label="ParallelCollectionRDD [89] start at FileStorageAdapterImpl.java:174}"]; 90 [id="node_90" labelType="html" label="MapPartitionsRDD [90] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_192 { id="cluster_192"; isCluster="true"; label="Exchange"; 91 [id="node_91" labelType="html" label="MapPartitionsRDD [91] start at FileStorageAdapterImpl.java:174}"]; } } 89->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"; 83 [id="node_83" labelType="html" label="ParallelCollectionRDD [83] start at FileStorageAdapterImpl.java:174}"]; 85 [id="node_85" labelType="html" label="MapPartitionsRDD [85] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_195 { id="cluster_195"; isCluster="true"; label="Exchange"; 87 [id="node_87" labelType="html" label="MapPartitionsRDD [87] start at FileStorageAdapterImpl.java:174}"]; } } 83->85; 85->87; }

digraph G { id="graph_31"; subgraph graph_stage_31 { id="graph_stage_31"; isCluster="true"; label="Stage 31 (skipped)"; subgraph cluster_209 { id="cluster_209"; isCluster="true"; label="AQEShuffleRead"; 92 [id="node_92" labelType="html" label="ShuffledRowRDD [92] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_206 { id="cluster_206"; isCluster="true"; label="WholeStageCodegen (1)"; 93 [id="node_93" labelType="html" label="MapPartitionsRDD [93] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_214 { id="cluster_214"; isCluster="true"; label="AQEShuffleRead"; 94 [id="node_94" labelType="html" label="ShuffledRowRDD [94] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_211 { id="cluster_211"; isCluster="true"; label="WholeStageCodegen (2)"; 95 [id="node_95" labelType="html" label="MapPartitionsRDD [95] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_202 { id="cluster_202"; isCluster="true"; label="WholeStageCodegen (3)"; 96 [id="node_96" labelType="html" label="ZippedPartitionsRDD2 [96] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 97 [id="node_97" labelType="html" label="MapPartitionsRDD [97] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_201 { id="cluster_201"; isCluster="true"; label="Exchange"; 98 [id="node_98" labelType="html" label="MapPartitionsRDD [98] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 92->93; 94->95; 93->96; 95->96; 96->97; 97->98; }

91,92

87,94

digraph G { id="graph_32"; subgraph graph_stage_32 { id="graph_stage_32"; isCluster="true"; label="Stage 32 (skipped)"; subgraph cluster_199 { id="cluster_199"; isCluster="true"; label="LocalTableScan"; 84 [id="node_84" labelType="html" label="ParallelCollectionRDD [84] start at FileStorageAdapterImpl.java:174}"]; 86 [id="node_86" labelType="html" label="MapPartitionsRDD [86] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_198 { id="cluster_198"; isCluster="true"; label="Exchange"; 88 [id="node_88" labelType="html" label="MapPartitionsRDD [88] start at FileStorageAdapterImpl.java:174}"]; } } 84->86; 86->88; }

digraph G { id="graph_33"; subgraph graph_stage_33 { id="graph_stage_33"; isCluster="true"; label="Stage 33"; subgraph cluster_224 { id="cluster_224"; isCluster="true"; label="AQEShuffleRead"; 99 [id="node_99" labelType="html" label="ShuffledRowRDD [99] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_221 { id="cluster_221"; isCluster="true"; label="WholeStageCodegen (4)"; 100 [id="node_100" labelType="html" label="MapPartitionsRDD [100] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_229 { id="cluster_229"; isCluster="true"; label="AQEShuffleRead"; 101 [id="node_101" labelType="html" label="ShuffledRowRDD [101] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_226 { id="cluster_226"; isCluster="true"; label="WholeStageCodegen (5)"; 102 [id="node_102" labelType="html" label="MapPartitionsRDD [102] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_216 { id="cluster_216"; isCluster="true"; label="WholeStageCodegen (6)"; 103 [id="node_103" labelType="html" label="ZippedPartitionsRDD2 [103] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 104 [id="node_104" labelType="html" label="MapPartitionsRDD [104] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_215 { id="cluster_215"; isCluster="true"; label="WriteFiles"; 105 [id="node_105" labelType="html" label="MapPartitionsRDD [105] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 99->100; 101->102; 100->103; 102->103; 103->104; 104->105; }

98,99

88,101

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
33	tenants-pool-768	stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) 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: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/04/10 15:02:25	2 s	1/1		32.5 KiB	1442.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-768

stream-10000000279-1 id = 7151e786-930f-48b5-abd8-3418e509a3bd runId = d58a1c7f-ab9a-4b00-80b4-c95a8c3b1c19 batch = 0 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
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: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/04/10 15:02:25

2 s

1/1

32.5 KiB

1442.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
32	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) 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: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:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) 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: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:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) 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: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:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) 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: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: