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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:55
Duration: 0.9 s
Associated SQL Query: 29
Job Group: 49208f80-235d-43ef-8cae-50261bfa1fbb
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_458 { id="cluster_458"; isCluster="true"; label="LocalTableScan"; 200 [id="node_200" labelType="html" label="ParallelCollectionRDD [200] start at FileStorageAdapterImpl.java:171}"]; 202 [id="node_202" labelType="html" label="MapPartitionsRDD [202] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_457 { id="cluster_457"; isCluster="true"; label="Exchange"; 204 [id="node_204" labelType="html" label="MapPartitionsRDD [204] start at FileStorageAdapterImpl.java:171}"]; } } 200->202; 202->204; }

digraph G { id="graph_64"; subgraph graph_stage_64 { id="graph_stage_64"; isCluster="true"; label="Stage 64 (skipped)"; subgraph cluster_452 { id="cluster_452"; isCluster="true"; label="LocalTableScan"; 205 [id="node_205" labelType="html" label="ParallelCollectionRDD [205] start at FileStorageAdapterImpl.java:171}"]; 206 [id="node_206" labelType="html" label="MapPartitionsRDD [206] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_451 { id="cluster_451"; isCluster="true"; label="Exchange"; 207 [id="node_207" labelType="html" label="MapPartitionsRDD [207] start at FileStorageAdapterImpl.java:171}"]; } } 205->206; 206->207; }

digraph G { id="graph_65"; subgraph graph_stage_65 { id="graph_stage_65"; isCluster="true"; label="Stage 65 (skipped)"; subgraph cluster_455 { id="cluster_455"; isCluster="true"; label="LocalTableScan"; 199 [id="node_199" labelType="html" label="ParallelCollectionRDD [199] start at FileStorageAdapterImpl.java:171}"]; 201 [id="node_201" labelType="html" label="MapPartitionsRDD [201] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_454 { id="cluster_454"; isCluster="true"; label="Exchange"; 203 [id="node_203" labelType="html" label="MapPartitionsRDD [203] start at FileStorageAdapterImpl.java:171}"]; } } 199->201; 201->203; }

digraph G { id="graph_66"; subgraph graph_stage_66 { id="graph_stage_66"; isCluster="true"; label="Stage 66 (skipped)"; subgraph cluster_468 { id="cluster_468"; isCluster="true"; label="AQEShuffleRead"; 208 [id="node_208" labelType="html" label="ShuffledRowRDD [208] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_465 { id="cluster_465"; isCluster="true"; label="WholeStageCodegen (1)"; 209 [id="node_209" labelType="html" label="MapPartitionsRDD [209] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_473 { id="cluster_473"; isCluster="true"; label="AQEShuffleRead"; 210 [id="node_210" labelType="html" label="ShuffledRowRDD [210] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_470 { id="cluster_470"; isCluster="true"; label="WholeStageCodegen (2)"; 211 [id="node_211" labelType="html" label="MapPartitionsRDD [211] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_461 { id="cluster_461"; isCluster="true"; label="WholeStageCodegen (3)"; 212 [id="node_212" labelType="html" label="ZippedPartitionsRDD2 [212] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 213 [id="node_213" labelType="html" label="MapPartitionsRDD [213] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_460 { id="cluster_460"; isCluster="true"; label="Exchange"; 214 [id="node_214" labelType="html" label="MapPartitionsRDD [214] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 208->209; 210->211; 209->212; 211->212; 212->213; 213->214; }

207,208

203,210

digraph G { id="graph_67"; subgraph graph_stage_67 { id="graph_stage_67"; isCluster="true"; label="Stage 67"; subgraph cluster_483 { id="cluster_483"; isCluster="true"; label="AQEShuffleRead"; 215 [id="node_215" labelType="html" label="ShuffledRowRDD [215] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_480 { id="cluster_480"; isCluster="true"; label="WholeStageCodegen (4)"; 216 [id="node_216" labelType="html" label="MapPartitionsRDD [216] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_488 { id="cluster_488"; isCluster="true"; label="AQEShuffleRead"; 217 [id="node_217" labelType="html" label="ShuffledRowRDD [217] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_485 { id="cluster_485"; isCluster="true"; label="WholeStageCodegen (5)"; 218 [id="node_218" labelType="html" label="MapPartitionsRDD [218] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_475 { id="cluster_475"; isCluster="true"; label="WholeStageCodegen (6)"; 219 [id="node_219" labelType="html" label="ZippedPartitionsRDD2 [219] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 220 [id="node_220" labelType="html" label="MapPartitionsRDD [220] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_474 { id="cluster_474"; isCluster="true"; label="WriteFiles"; 221 [id="node_221" labelType="html" label="MapPartitionsRDD [221] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 215->216; 217->218; 216->219; 218->219; 219->220; 220->221; }

214,215

204,217

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-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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 10:33:55	0.9 s	1/1		32.5 KiB	1413.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-286

stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb 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 10:33:55

0.9 s

1/1

32.5 KiB

1413.0 B

Page:

Skipped Stages (4)

Page:

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