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

Status: SUCCEEDED
Submitted: 2026/04/11 14:40:37
Duration: 2 s
Associated SQL Query: 27
Job Group: a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_63"; subgraph graph_stage_63 { id="graph_stage_63"; isCluster="true"; label="Stage 63 (skipped)"; subgraph cluster_452 { id="cluster_452"; isCluster="true"; label="LocalTableScan"; 190 [id="node_190" labelType="html" label="ParallelCollectionRDD [190] start at FileStorageAdapterImpl.java:174}"]; 191 [id="node_191" labelType="html" label="MapPartitionsRDD [191] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_451 { id="cluster_451"; isCluster="true"; label="Exchange"; 194 [id="node_194" labelType="html" label="MapPartitionsRDD [194] start at FileStorageAdapterImpl.java:174}"]; } } 190->191; 191->194; }

digraph G { id="graph_64"; subgraph graph_stage_64 { id="graph_stage_64"; isCluster="true"; label="Stage 64 (skipped)"; subgraph cluster_446 { id="cluster_446"; isCluster="true"; label="LocalTableScan"; 195 [id="node_195" labelType="html" label="ParallelCollectionRDD [195] start at FileStorageAdapterImpl.java:174}"]; 196 [id="node_196" labelType="html" label="MapPartitionsRDD [196] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_445 { id="cluster_445"; isCluster="true"; label="Exchange"; 197 [id="node_197" labelType="html" label="MapPartitionsRDD [197] start at FileStorageAdapterImpl.java:174}"]; } } 195->196; 196->197; }

digraph G { id="graph_65"; subgraph graph_stage_65 { id="graph_stage_65"; isCluster="true"; label="Stage 65 (skipped)"; subgraph cluster_449 { id="cluster_449"; isCluster="true"; label="LocalTableScan"; 189 [id="node_189" labelType="html" label="ParallelCollectionRDD [189] start at FileStorageAdapterImpl.java:174}"]; 192 [id="node_192" labelType="html" label="MapPartitionsRDD [192] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_448 { id="cluster_448"; isCluster="true"; label="Exchange"; 193 [id="node_193" labelType="html" label="MapPartitionsRDD [193] start at FileStorageAdapterImpl.java:174}"]; } } 189->192; 192->193; }

digraph G { id="graph_66"; subgraph graph_stage_66 { id="graph_stage_66"; isCluster="true"; label="Stage 66 (skipped)"; subgraph cluster_462 { id="cluster_462"; isCluster="true"; label="AQEShuffleRead"; 198 [id="node_198" labelType="html" label="ShuffledRowRDD [198] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_459 { id="cluster_459"; isCluster="true"; label="WholeStageCodegen (1)"; 199 [id="node_199" labelType="html" label="MapPartitionsRDD [199] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_467 { id="cluster_467"; isCluster="true"; label="AQEShuffleRead"; 200 [id="node_200" labelType="html" label="ShuffledRowRDD [200] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_464 { id="cluster_464"; isCluster="true"; label="WholeStageCodegen (2)"; 201 [id="node_201" labelType="html" label="MapPartitionsRDD [201] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_455 { id="cluster_455"; isCluster="true"; label="WholeStageCodegen (3)"; 202 [id="node_202" labelType="html" label="ZippedPartitionsRDD2 [202] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 203 [id="node_203" labelType="html" label="MapPartitionsRDD [203] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_454 { id="cluster_454"; isCluster="true"; label="Exchange"; 204 [id="node_204" labelType="html" label="MapPartitionsRDD [204] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 198->199; 200->201; 199->202; 201->202; 202->203; 203->204; }

197,198

193,200

digraph G { id="graph_67"; subgraph graph_stage_67 { id="graph_stage_67"; isCluster="true"; label="Stage 67"; subgraph cluster_477 { id="cluster_477"; isCluster="true"; label="AQEShuffleRead"; 205 [id="node_205" labelType="html" label="ShuffledRowRDD [205] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_474 { id="cluster_474"; isCluster="true"; label="WholeStageCodegen (4)"; 206 [id="node_206" labelType="html" label="MapPartitionsRDD [206] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_482 { id="cluster_482"; isCluster="true"; label="AQEShuffleRead"; 207 [id="node_207" labelType="html" label="ShuffledRowRDD [207] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_479 { id="cluster_479"; isCluster="true"; label="WholeStageCodegen (5)"; 208 [id="node_208" labelType="html" label="MapPartitionsRDD [208] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_469 { id="cluster_469"; isCluster="true"; label="WholeStageCodegen (6)"; 209 [id="node_209" labelType="html" label="ZippedPartitionsRDD2 [209] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 210 [id="node_210" labelType="html" label="MapPartitionsRDD [210] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_468 { id="cluster_468"; isCluster="true"; label="WriteFiles"; 211 [id="node_211" labelType="html" label="MapPartitionsRDD [211] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 205->206; 207->208; 206->209; 208->209; 209->210; 210->211; }

204,205

194,207

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
67	tenants-pool-286	stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c 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/11 14:40:37	2 s	1/1		32.5 KiB	1432.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-286

stream-10000000120-1 id = 34d1c485-0ed8-49c8-9158-02d9f619dcf6 runId = a66321e4-3cc0-4d71-b1ca-59b86c7a2e2c 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/11 14:40:37

2 s

1/1

32.5 KiB

1432.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
66	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
65	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
64	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
63	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: