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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:30
Duration: 3 s
Associated SQL Query: 830
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 6

Enable zooming

digraph G { id="graph_3938"; subgraph graph_stage_3938 { id="graph_stage_3938"; isCluster="true"; label="Stage 3938"; subgraph cluster_27306 { id="cluster_27306"; isCluster="true"; label="Scan parquet "; 10117 [id="node_10117" labelType="html" label="FileScanRDD [10117] start at FileStorageAdapterImpl.java:177}"]; 10118 [id="node_10118" labelType="html" label="MapPartitionsRDD [10118] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27302 { id="cluster_27302"; isCluster="true"; label="WholeStageCodegen (7)"; 10119 [id="node_10119" labelType="html" label="MapPartitionsRDD [10119] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27301 { id="cluster_27301"; isCluster="true"; label="Exchange"; 10120 [id="node_10120" labelType="html" label="MapPartitionsRDD [10120] start at FileStorageAdapterImpl.java:177}"]; } } 10117->10118; 10118->10119; 10119->10120; }

digraph G { id="graph_3939"; subgraph graph_stage_3939 { id="graph_stage_3939"; isCluster="true"; label="Stage 3939"; subgraph cluster_27280 { id="cluster_27280"; isCluster="true"; label="Scan parquet "; 10106 [id="node_10106" labelType="html" label="FileScanRDD [10106] start at FileStorageAdapterImpl.java:177}"]; 10107 [id="node_10107" labelType="html" label="MapPartitionsRDD [10107] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27276 { id="cluster_27276"; isCluster="true"; label="WholeStageCodegen (1)"; 10108 [id="node_10108" labelType="html" label="MapPartitionsRDD [10108] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27275 { id="cluster_27275"; isCluster="true"; label="Exchange"; 10109 [id="node_10109" labelType="html" label="MapPartitionsRDD [10109] start at FileStorageAdapterImpl.java:177}"]; } } 10106->10107; 10107->10108; 10108->10109; }

digraph G { id="graph_3940"; subgraph graph_stage_3940 { id="graph_stage_3940"; isCluster="true"; label="Stage 3940"; subgraph cluster_27275 { id="cluster_27275"; isCluster="true"; label="Exchange"; 10110 [id="node_10110" labelType="html" label="ShuffledRowRDD [10110] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27247 { id="cluster_27247"; isCluster="true"; label="WholeStageCodegen (5)"; 10111 [id="node_10111" labelType="html" label="MapPartitionsRDD [10111] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27246 { id="cluster_27246"; isCluster="true"; label="Exchange"; 10112 [id="node_10112" labelType="html" label="MapPartitionsRDD [10112] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10110->10111; 10111->10112; }

10109,10110

digraph G { id="graph_3941"; subgraph graph_stage_3941 { id="graph_stage_3941"; isCluster="true"; label="Stage 3941"; subgraph cluster_27301 { id="cluster_27301"; isCluster="true"; label="Exchange"; 10121 [id="node_10121" labelType="html" label="ShuffledRowRDD [10121] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27286 { id="cluster_27286"; isCluster="true"; label="WholeStageCodegen (11)"; 10122 [id="node_10122" labelType="html" label="MapPartitionsRDD [10122] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27285 { id="cluster_27285"; isCluster="true"; label="Exchange"; 10123 [id="node_10123" labelType="html" label="MapPartitionsRDD [10123] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10121->10122; 10122->10123; }

10120,10121

digraph G { id="graph_3942"; subgraph graph_stage_3942 { id="graph_stage_3942"; isCluster="true"; label="Stage 3942"; subgraph cluster_27246 { id="cluster_27246"; isCluster="true"; label="Exchange"; 10113 [id="node_10113" labelType="html" label="ShuffledRowRDD [10113] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27243 { id="cluster_27243"; isCluster="true"; label="WholeStageCodegen (6)"; 10114 [id="node_10114" labelType="html" label="MapPartitionsRDD [10114] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27285 { id="cluster_27285"; isCluster="true"; label="Exchange"; 10124 [id="node_10124" labelType="html" label="ShuffledRowRDD [10124] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27282 { id="cluster_27282"; isCluster="true"; label="WholeStageCodegen (12)"; 10125 [id="node_10125" labelType="html" label="MapPartitionsRDD [10125] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27239 { id="cluster_27239"; isCluster="true"; label="WholeStageCodegen (13)"; 10126 [id="node_10126" labelType="html" label="ZippedPartitionsRDD2 [10126] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10127 [id="node_10127" labelType="html" label="MapPartitionsRDD [10127] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27238 { id="cluster_27238"; isCluster="true"; label="ObjectHashAggregate"; 10128 [id="node_10128" labelType="html" label="MapPartitionsRDD [10128] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27237 { id="cluster_27237"; isCluster="true"; label="Exchange"; 10129 [id="node_10129" labelType="html" label="MapPartitionsRDD [10129] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10113->10114; 10124->10125; 10114->10126; 10125->10126; 10126->10127; 10127->10128; 10128->10129; }

10112,10113

10123,10124

digraph G { id="graph_3943"; subgraph graph_stage_3943 { id="graph_stage_3943"; isCluster="true"; label="Stage 3943"; 10138 [id="node_10138" labelType="html" label="SQLExecutionRDD [10138] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_27237 { id="cluster_27237"; isCluster="true"; label="Exchange"; 10130 [id="node_10130" labelType="html" label="ShuffledRowRDD [10130] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27236 { id="cluster_27236"; isCluster="true"; label="ObjectHashAggregate"; 10131 [id="node_10131" labelType="html" label="MapPartitionsRDD [10131] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27235 { id="cluster_27235"; isCluster="true"; label="Project"; 10132 [id="node_10132" labelType="html" label="MapPartitionsRDD [10132] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27228 { id="cluster_27228"; isCluster="true"; label="WholeStageCodegen (16)"; 10133 [id="node_10133" labelType="html" label="MapPartitionsRDD [10133] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27227 { id="cluster_27227"; isCluster="true"; label="DeserializeToObject"; 10134 [id="node_10134" labelType="html" label="MapPartitionsRDD [10134] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27226 { id="cluster_27226"; isCluster="true"; label="MapPartitions"; 10135 [id="node_10135" labelType="html" label="MapPartitionsRDD [10135] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27158 { id="cluster_27158"; isCluster="true"; label="WholeStageCodegen (19)"; 10136 [id="node_10136" labelType="html" label="MapPartitionsRDD [10136] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27137 { id="cluster_27137"; isCluster="true"; label="DeserializeToObject"; 10137 [id="node_10137" labelType="html" label="MapPartitionsRDD [10137] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27314 { id="cluster_27314"; isCluster="true"; label="mapPartitions"; 10139 [id="node_10139" labelType="html" label="MapPartitionsRDD [10139] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27315 { id="cluster_27315"; isCluster="true"; label="mapPartitions"; 10140 [id="node_10140" labelType="html" label="MapPartitionsRDD [10140] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10130->10131; 10131->10132; 10132->10133; 10133->10134; 10134->10135; 10135->10136; 10136->10137; 10137->10138; 10138->10139; 10139->10140; }

10129,10130

10140

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3943	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:31	2 s	20/20	160.2 KiB
3942	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:31	0.4 s	20/20	207.0 KiB	160.2 KiB
3941	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:31	0.2 s	20/20	43.6 KiB	50.7 KiB
3940	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:31	0.1 s	20/20	79.5 KiB	156.3 KiB
3939	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:30	0.2 s	1/1		79.5 KiB
3938	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:30	0.1 s	1/1		43.6 KiB

Page: