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

Status: SUCCEEDED
Submitted: 2026/04/20 06:43:36
Duration: 2 s
Associated SQL Query: 101
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_970"; subgraph graph_stage_970 { id="graph_stage_970"; isCluster="true"; label="Stage 970 (skipped)"; subgraph cluster_3774 { id="cluster_3774"; isCluster="true"; label="LocalTableScan"; 1424 [id="node_1424" labelType="html" label="ParallelCollectionRDD [1424] start at FileStorageAdapterImpl.java:171}"]; 1426 [id="node_1426" labelType="html" label="MapPartitionsRDD [1426] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3773 { id="cluster_3773"; isCluster="true"; label="Exchange"; 1428 [id="node_1428" labelType="html" label="MapPartitionsRDD [1428] start at FileStorageAdapterImpl.java:171}"]; } } 1424->1426; 1426->1428; }

digraph G { id="graph_971"; subgraph graph_stage_971 { id="graph_stage_971"; isCluster="true"; label="Stage 971 (skipped)"; subgraph cluster_3771 { id="cluster_3771"; isCluster="true"; label="LocalTableScan"; 1430 [id="node_1430" labelType="html" label="ParallelCollectionRDD [1430] start at FileStorageAdapterImpl.java:171}"]; 1431 [id="node_1431" labelType="html" label="MapPartitionsRDD [1431] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3770 { id="cluster_3770"; isCluster="true"; label="Exchange"; 1432 [id="node_1432" labelType="html" label="MapPartitionsRDD [1432] start at FileStorageAdapterImpl.java:171}"]; } } 1430->1431; 1431->1432; }

digraph G { id="graph_972"; subgraph graph_stage_972 { id="graph_stage_972"; isCluster="true"; label="Stage 972 (skipped)"; subgraph cluster_3787 { id="cluster_3787"; isCluster="true"; label="AQEShuffleRead"; 1433 [id="node_1433" labelType="html" label="ShuffledRowRDD [1433] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3784 { id="cluster_3784"; isCluster="true"; label="WholeStageCodegen (1)"; 1434 [id="node_1434" labelType="html" label="MapPartitionsRDD [1434] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3792 { id="cluster_3792"; isCluster="true"; label="AQEShuffleRead"; 1435 [id="node_1435" labelType="html" label="ShuffledRowRDD [1435] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3789 { id="cluster_3789"; isCluster="true"; label="WholeStageCodegen (2)"; 1436 [id="node_1436" labelType="html" label="MapPartitionsRDD [1436] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3780 { id="cluster_3780"; isCluster="true"; label="WholeStageCodegen (3)"; 1437 [id="node_1437" labelType="html" label="ZippedPartitionsRDD2 [1437] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1438 [id="node_1438" labelType="html" label="MapPartitionsRDD [1438] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3779 { id="cluster_3779"; isCluster="true"; label="Exchange"; 1439 [id="node_1439" labelType="html" label="MapPartitionsRDD [1439] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1433->1434; 1435->1436; 1434->1437; 1436->1437; 1437->1438; 1438->1439; }

1432,1433

1428,1435

digraph G { id="graph_973"; subgraph graph_stage_973 { id="graph_stage_973"; isCluster="true"; label="Stage 973 (skipped)"; subgraph cluster_3777 { id="cluster_3777"; isCluster="true"; label="LocalTableScan"; 1425 [id="node_1425" labelType="html" label="ParallelCollectionRDD [1425] start at FileStorageAdapterImpl.java:171}"]; 1427 [id="node_1427" labelType="html" label="MapPartitionsRDD [1427] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3776 { id="cluster_3776"; isCluster="true"; label="Exchange"; 1429 [id="node_1429" labelType="html" label="MapPartitionsRDD [1429] start at FileStorageAdapterImpl.java:171}"]; } } 1425->1427; 1427->1429; }

digraph G { id="graph_974"; subgraph graph_stage_974 { id="graph_stage_974"; isCluster="true"; label="Stage 974"; subgraph cluster_3802 { id="cluster_3802"; isCluster="true"; label="AQEShuffleRead"; 1440 [id="node_1440" labelType="html" label="ShuffledRowRDD [1440] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3799 { id="cluster_3799"; isCluster="true"; label="WholeStageCodegen (4)"; 1441 [id="node_1441" labelType="html" label="MapPartitionsRDD [1441] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3807 { id="cluster_3807"; isCluster="true"; label="AQEShuffleRead"; 1442 [id="node_1442" labelType="html" label="ShuffledRowRDD [1442] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3804 { id="cluster_3804"; isCluster="true"; label="WholeStageCodegen (5)"; 1443 [id="node_1443" labelType="html" label="MapPartitionsRDD [1443] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3794 { id="cluster_3794"; isCluster="true"; label="WholeStageCodegen (6)"; 1444 [id="node_1444" labelType="html" label="ZippedPartitionsRDD2 [1444] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1445 [id="node_1445" labelType="html" label="MapPartitionsRDD [1445] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3793 { id="cluster_3793"; isCluster="true"; label="WriteFiles"; 1446 [id="node_1446" labelType="html" label="MapPartitionsRDD [1446] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1440->1441; 1442->1443; 1441->1444; 1443->1444; 1444->1445; 1445->1446; }

1439,1440

1429,1442

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
974	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2 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/04/20 06:43:36	2 s	1/1		35.9 KiB	6.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

974

tenants-pool-506

stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2 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/04/20 06:43:36

2 s

1/1

35.9 KiB

6.6 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
973	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/18
972	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
971	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/18
970	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/18

Page: