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

Status: SUCCEEDED
Submitted: 2026/08/10 08:18:52
Duration: 3 s
Associated SQL Query: 103
Job Group: f6fc2d63-a255-4383-a46a-6581aeff922a
Completed Stages: 6

Enable zooming

digraph G { id="graph_725"; subgraph graph_stage_725 { id="graph_stage_725"; isCluster="true"; label="Stage 725"; subgraph cluster_3304 { id="cluster_3304"; isCluster="true"; label="Scan parquet "; 1302 [id="node_1302" labelType="html" label="FileScanRDD [1302] start at FileStorageAdapterImpl.java:177}"]; 1303 [id="node_1303" labelType="html" label="MapPartitionsRDD [1303] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3300 { id="cluster_3300"; isCluster="true"; label="WholeStageCodegen (1)"; 1304 [id="node_1304" labelType="html" label="MapPartitionsRDD [1304] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3299 { id="cluster_3299"; isCluster="true"; label="Exchange"; 1305 [id="node_1305" labelType="html" label="MapPartitionsRDD [1305] start at FileStorageAdapterImpl.java:177}"]; } } 1302->1303; 1303->1304; 1304->1305; }

digraph G { id="graph_726"; subgraph graph_stage_726 { id="graph_stage_726"; isCluster="true"; label="Stage 726"; subgraph cluster_3330 { id="cluster_3330"; isCluster="true"; label="Scan parquet "; 1313 [id="node_1313" labelType="html" label="FileScanRDD [1313] start at FileStorageAdapterImpl.java:177}"]; 1314 [id="node_1314" labelType="html" label="MapPartitionsRDD [1314] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3326 { id="cluster_3326"; isCluster="true"; label="WholeStageCodegen (7)"; 1315 [id="node_1315" labelType="html" label="MapPartitionsRDD [1315] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="Exchange"; 1316 [id="node_1316" labelType="html" label="MapPartitionsRDD [1316] start at FileStorageAdapterImpl.java:177}"]; } } 1313->1314; 1314->1315; 1315->1316; }

digraph G { id="graph_727"; subgraph graph_stage_727 { id="graph_stage_727"; isCluster="true"; label="Stage 727"; subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="Exchange"; 1317 [id="node_1317" labelType="html" label="ShuffledRowRDD [1317] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3310 { id="cluster_3310"; isCluster="true"; label="WholeStageCodegen (11)"; 1318 [id="node_1318" labelType="html" label="MapPartitionsRDD [1318] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3309 { id="cluster_3309"; isCluster="true"; label="Exchange"; 1319 [id="node_1319" labelType="html" label="MapPartitionsRDD [1319] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1317->1318; 1318->1319; }

1316,1317

digraph G { id="graph_728"; subgraph graph_stage_728 { id="graph_stage_728"; isCluster="true"; label="Stage 728"; subgraph cluster_3299 { id="cluster_3299"; isCluster="true"; label="Exchange"; 1306 [id="node_1306" labelType="html" label="ShuffledRowRDD [1306] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (5)"; 1307 [id="node_1307" labelType="html" label="MapPartitionsRDD [1307] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3270 { id="cluster_3270"; isCluster="true"; label="Exchange"; 1308 [id="node_1308" labelType="html" label="MapPartitionsRDD [1308] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1306->1307; 1307->1308; }

1305,1306

digraph G { id="graph_729"; subgraph graph_stage_729 { id="graph_stage_729"; isCluster="true"; label="Stage 729"; subgraph cluster_3270 { id="cluster_3270"; isCluster="true"; label="Exchange"; 1309 [id="node_1309" labelType="html" label="ShuffledRowRDD [1309] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3267 { id="cluster_3267"; isCluster="true"; label="WholeStageCodegen (6)"; 1310 [id="node_1310" labelType="html" label="MapPartitionsRDD [1310] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3309 { id="cluster_3309"; isCluster="true"; label="Exchange"; 1320 [id="node_1320" labelType="html" label="ShuffledRowRDD [1320] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3306 { id="cluster_3306"; isCluster="true"; label="WholeStageCodegen (12)"; 1321 [id="node_1321" labelType="html" label="MapPartitionsRDD [1321] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3263 { id="cluster_3263"; isCluster="true"; label="WholeStageCodegen (13)"; 1322 [id="node_1322" labelType="html" label="ZippedPartitionsRDD2 [1322] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1323 [id="node_1323" labelType="html" label="MapPartitionsRDD [1323] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="ObjectHashAggregate"; 1324 [id="node_1324" labelType="html" label="MapPartitionsRDD [1324] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3261 { id="cluster_3261"; isCluster="true"; label="Exchange"; 1325 [id="node_1325" labelType="html" label="MapPartitionsRDD [1325] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1309->1310; 1320->1321; 1310->1322; 1321->1322; 1322->1323; 1323->1324; 1324->1325; }

1308,1309

1319,1320

digraph G { id="graph_730"; subgraph graph_stage_730 { id="graph_stage_730"; isCluster="true"; label="Stage 730"; 1334 [id="node_1334" labelType="html" label="SQLExecutionRDD [1334] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_3261 { id="cluster_3261"; isCluster="true"; label="Exchange"; 1326 [id="node_1326" labelType="html" label="ShuffledRowRDD [1326] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3260 { id="cluster_3260"; isCluster="true"; label="ObjectHashAggregate"; 1327 [id="node_1327" labelType="html" label="MapPartitionsRDD [1327] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3259 { id="cluster_3259"; isCluster="true"; label="Project"; 1328 [id="node_1328" labelType="html" label="MapPartitionsRDD [1328] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3252 { id="cluster_3252"; isCluster="true"; label="WholeStageCodegen (16)"; 1329 [id="node_1329" labelType="html" label="MapPartitionsRDD [1329] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3251 { id="cluster_3251"; isCluster="true"; label="DeserializeToObject"; 1330 [id="node_1330" labelType="html" label="MapPartitionsRDD [1330] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3250 { id="cluster_3250"; isCluster="true"; label="MapPartitions"; 1331 [id="node_1331" labelType="html" label="MapPartitionsRDD [1331] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3182 { id="cluster_3182"; isCluster="true"; label="WholeStageCodegen (19)"; 1332 [id="node_1332" labelType="html" label="MapPartitionsRDD [1332] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3161 { id="cluster_3161"; isCluster="true"; label="DeserializeToObject"; 1333 [id="node_1333" labelType="html" label="MapPartitionsRDD [1333] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3338 { id="cluster_3338"; isCluster="true"; label="mapPartitions"; 1335 [id="node_1335" labelType="html" label="MapPartitionsRDD [1335] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3339 { id="cluster_3339"; isCluster="true"; label="mapPartitions"; 1336 [id="node_1336" labelType="html" label="MapPartitionsRDD [1336] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1326->1327; 1327->1328; 1328->1329; 1329->1330; 1330->1331; 1331->1332; 1332->1333; 1333->1334; 1334->1335; 1335->1336; }

1325,1326

1336

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
730	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:53	2 s	20/20	578.1 KiB
729	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:53	0.4 s	20/20	765.4 KiB	578.1 KiB
728	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:53	0.1 s	20/20	79.4 KiB	572.6 KiB
727	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:53	0.2 s	20/20	43.6 KiB	192.8 KiB
726	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:52	0.2 s	1/1		43.6 KiB
725	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 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 08:18:52	0.2 s	1/1		79.4 KiB

Page: