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

Status: SUCCEEDED
Submitted: 2026/07/05 14:35:45
Duration: 0.5 s
Associated SQL Query: 317
Job Group: cd2848b0-327d-42fa-997f-ab27cc4e5d7d
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_1465"; subgraph graph_stage_1465 { id="graph_stage_1465"; isCluster="true"; label="Stage 1465 (skipped)"; subgraph cluster_11880 { id="cluster_11880"; isCluster="true"; label="LocalTableScan"; 3802 [id="node_3802" labelType="html" label="ParallelCollectionRDD [3802] start at FileStorageAdapterImpl.java:174}"]; 3804 [id="node_3804" labelType="html" label="MapPartitionsRDD [3804] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11879 { id="cluster_11879"; isCluster="true"; label="Exchange"; 3806 [id="node_3806" labelType="html" label="MapPartitionsRDD [3806] start at FileStorageAdapterImpl.java:174}"]; } } 3802->3804; 3804->3806; }

digraph G { id="graph_1466"; subgraph graph_stage_1466 { id="graph_stage_1466"; isCluster="true"; label="Stage 1466 (skipped)"; subgraph cluster_11877 { id="cluster_11877"; isCluster="true"; label="LocalTableScan"; 3808 [id="node_3808" labelType="html" label="ParallelCollectionRDD [3808] start at FileStorageAdapterImpl.java:174}"]; 3809 [id="node_3809" labelType="html" label="MapPartitionsRDD [3809] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11876 { id="cluster_11876"; isCluster="true"; label="Exchange"; 3810 [id="node_3810" labelType="html" label="MapPartitionsRDD [3810] start at FileStorageAdapterImpl.java:174}"]; } } 3808->3809; 3809->3810; }

digraph G { id="graph_1467"; subgraph graph_stage_1467 { id="graph_stage_1467"; isCluster="true"; label="Stage 1467 (skipped)"; subgraph cluster_11893 { id="cluster_11893"; isCluster="true"; label="AQEShuffleRead"; 3811 [id="node_3811" labelType="html" label="ShuffledRowRDD [3811] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11890 { id="cluster_11890"; isCluster="true"; label="WholeStageCodegen (1)"; 3812 [id="node_3812" labelType="html" label="MapPartitionsRDD [3812] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11898 { id="cluster_11898"; isCluster="true"; label="AQEShuffleRead"; 3813 [id="node_3813" labelType="html" label="ShuffledRowRDD [3813] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11895 { id="cluster_11895"; isCluster="true"; label="WholeStageCodegen (2)"; 3814 [id="node_3814" labelType="html" label="MapPartitionsRDD [3814] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11886 { id="cluster_11886"; isCluster="true"; label="WholeStageCodegen (3)"; 3815 [id="node_3815" labelType="html" label="ZippedPartitionsRDD2 [3815] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3816 [id="node_3816" labelType="html" label="MapPartitionsRDD [3816] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11885 { id="cluster_11885"; isCluster="true"; label="Exchange"; 3817 [id="node_3817" labelType="html" label="MapPartitionsRDD [3817] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3811->3812; 3813->3814; 3812->3815; 3814->3815; 3815->3816; 3816->3817; }

3810,3811

3806,3813

digraph G { id="graph_1468"; subgraph graph_stage_1468 { id="graph_stage_1468"; isCluster="true"; label="Stage 1468 (skipped)"; subgraph cluster_11883 { id="cluster_11883"; isCluster="true"; label="LocalTableScan"; 3803 [id="node_3803" labelType="html" label="ParallelCollectionRDD [3803] start at FileStorageAdapterImpl.java:174}"]; 3805 [id="node_3805" labelType="html" label="MapPartitionsRDD [3805] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11882 { id="cluster_11882"; isCluster="true"; label="Exchange"; 3807 [id="node_3807" labelType="html" label="MapPartitionsRDD [3807] start at FileStorageAdapterImpl.java:174}"]; } } 3803->3805; 3805->3807; }

digraph G { id="graph_1469"; subgraph graph_stage_1469 { id="graph_stage_1469"; isCluster="true"; label="Stage 1469"; subgraph cluster_11908 { id="cluster_11908"; isCluster="true"; label="AQEShuffleRead"; 3818 [id="node_3818" labelType="html" label="ShuffledRowRDD [3818] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11905 { id="cluster_11905"; isCluster="true"; label="WholeStageCodegen (4)"; 3819 [id="node_3819" labelType="html" label="MapPartitionsRDD [3819] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11913 { id="cluster_11913"; isCluster="true"; label="AQEShuffleRead"; 3820 [id="node_3820" labelType="html" label="ShuffledRowRDD [3820] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11910 { id="cluster_11910"; isCluster="true"; label="WholeStageCodegen (5)"; 3821 [id="node_3821" labelType="html" label="MapPartitionsRDD [3821] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11900 { id="cluster_11900"; isCluster="true"; label="WholeStageCodegen (6)"; 3822 [id="node_3822" labelType="html" label="ZippedPartitionsRDD2 [3822] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3823 [id="node_3823" labelType="html" label="MapPartitionsRDD [3823] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11899 { id="cluster_11899"; isCluster="true"; label="WriteFiles"; 3824 [id="node_3824" labelType="html" label="MapPartitionsRDD [3824] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3818->3819; 3820->3821; 3819->3822; 3821->3822; 3822->3823; 3823->3824; }

3817,3818

3807,3820

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1469	tenants-pool-21	stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 3 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/07/05 14:35:45	0.5 s	1/1		35.5 KiB	5.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1469

tenants-pool-21

stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 3 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/07/05 14:35:45

0.5 s

1/1

35.5 KiB

5.8 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1468	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/10
1467	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
1466	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/10
1465	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/10

Page: