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

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

Enable zooming

digraph G { id="graph_800"; subgraph graph_stage_800 { id="graph_stage_800"; isCluster="true"; label="Stage 800"; subgraph cluster_3821 { id="cluster_3821"; isCluster="true"; label="Scan parquet "; 1516 [id="node_1516" labelType="html" label="FileScanRDD [1516] start at FileStorageAdapterImpl.java:177}"]; 1517 [id="node_1517" labelType="html" label="MapPartitionsRDD [1517] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3817 { id="cluster_3817"; isCluster="true"; label="WholeStageCodegen (1)"; 1518 [id="node_1518" labelType="html" label="MapPartitionsRDD [1518] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3816 { id="cluster_3816"; isCluster="true"; label="Exchange"; 1519 [id="node_1519" labelType="html" label="MapPartitionsRDD [1519] start at FileStorageAdapterImpl.java:177}"]; } } 1516->1517; 1517->1518; 1518->1519; }

digraph G { id="graph_801"; subgraph graph_stage_801 { id="graph_stage_801"; isCluster="true"; label="Stage 801"; subgraph cluster_3854 { id="cluster_3854"; isCluster="true"; label="Scan parquet "; 1527 [id="node_1527" labelType="html" label="FileScanRDD [1527] start at FileStorageAdapterImpl.java:177}"]; 1528 [id="node_1528" labelType="html" label="MapPartitionsRDD [1528] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3850 { id="cluster_3850"; isCluster="true"; label="WholeStageCodegen (7)"; 1529 [id="node_1529" labelType="html" label="MapPartitionsRDD [1529] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3849 { id="cluster_3849"; isCluster="true"; label="Exchange"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] start at FileStorageAdapterImpl.java:177}"]; } } 1527->1528; 1528->1529; 1529->1530; }

digraph G { id="graph_802"; subgraph graph_stage_802 { id="graph_stage_802"; isCluster="true"; label="Stage 802"; subgraph cluster_3849 { id="cluster_3849"; isCluster="true"; label="Exchange"; 1531 [id="node_1531" labelType="html" label="ShuffledRowRDD [1531] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3827 { id="cluster_3827"; isCluster="true"; label="WholeStageCodegen (11)"; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3826 { id="cluster_3826"; isCluster="true"; label="Exchange"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1531->1532; 1532->1533; }

1530,1531

digraph G { id="graph_803"; subgraph graph_stage_803 { id="graph_stage_803"; isCluster="true"; label="Stage 803"; subgraph cluster_3816 { id="cluster_3816"; isCluster="true"; label="Exchange"; 1520 [id="node_1520" labelType="html" label="ShuffledRowRDD [1520] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3795 { id="cluster_3795"; isCluster="true"; label="WholeStageCodegen (5)"; 1521 [id="node_1521" labelType="html" label="MapPartitionsRDD [1521] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3794 { id="cluster_3794"; isCluster="true"; label="Exchange"; 1522 [id="node_1522" labelType="html" label="MapPartitionsRDD [1522] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1520->1521; 1521->1522; }

1519,1520

digraph G { id="graph_804"; subgraph graph_stage_804 { id="graph_stage_804"; isCluster="true"; label="Stage 804"; subgraph cluster_3794 { id="cluster_3794"; isCluster="true"; label="Exchange"; 1523 [id="node_1523" labelType="html" label="ShuffledRowRDD [1523] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3791 { id="cluster_3791"; isCluster="true"; label="WholeStageCodegen (6)"; 1524 [id="node_1524" labelType="html" label="MapPartitionsRDD [1524] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3826 { id="cluster_3826"; isCluster="true"; label="Exchange"; 1534 [id="node_1534" labelType="html" label="ShuffledRowRDD [1534] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3823 { id="cluster_3823"; isCluster="true"; label="WholeStageCodegen (12)"; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3787 { id="cluster_3787"; isCluster="true"; label="WholeStageCodegen (13)"; 1536 [id="node_1536" labelType="html" label="ZippedPartitionsRDD2 [1536] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1537 [id="node_1537" labelType="html" label="MapPartitionsRDD [1537] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3786 { id="cluster_3786"; isCluster="true"; label="ObjectHashAggregate"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3785 { id="cluster_3785"; isCluster="true"; label="Exchange"; 1539 [id="node_1539" labelType="html" label="MapPartitionsRDD [1539] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1523->1524; 1534->1535; 1524->1536; 1535->1536; 1536->1537; 1537->1538; 1538->1539; }

1522,1523

1533,1534

digraph G { id="graph_805"; subgraph graph_stage_805 { id="graph_stage_805"; isCluster="true"; label="Stage 805"; 1548 [id="node_1548" labelType="html" label="SQLExecutionRDD [1548] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_3785 { id="cluster_3785"; isCluster="true"; label="Exchange"; 1540 [id="node_1540" labelType="html" label="ShuffledRowRDD [1540] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3784 { id="cluster_3784"; isCluster="true"; label="ObjectHashAggregate"; 1541 [id="node_1541" labelType="html" label="MapPartitionsRDD [1541] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3783 { id="cluster_3783"; isCluster="true"; label="Project"; 1542 [id="node_1542" labelType="html" label="MapPartitionsRDD [1542] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3776 { id="cluster_3776"; isCluster="true"; label="WholeStageCodegen (16)"; 1543 [id="node_1543" labelType="html" label="MapPartitionsRDD [1543] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3775 { id="cluster_3775"; isCluster="true"; label="DeserializeToObject"; 1544 [id="node_1544" labelType="html" label="MapPartitionsRDD [1544] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3757 { id="cluster_3757"; isCluster="true"; label="MapPartitions"; 1545 [id="node_1545" labelType="html" label="MapPartitionsRDD [1545] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3705 { id="cluster_3705"; isCluster="true"; label="WholeStageCodegen (19)"; 1546 [id="node_1546" labelType="html" label="MapPartitionsRDD [1546] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3685 { id="cluster_3685"; isCluster="true"; label="DeserializeToObject"; 1547 [id="node_1547" labelType="html" label="MapPartitionsRDD [1547] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3862 { id="cluster_3862"; isCluster="true"; label="mapPartitions"; 1549 [id="node_1549" labelType="html" label="MapPartitionsRDD [1549] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3863 { id="cluster_3863"; isCluster="true"; label="mapPartitions"; 1550 [id="node_1550" labelType="html" label="MapPartitionsRDD [1550] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1540->1541; 1541->1542; 1542->1543; 1543->1544; 1544->1545; 1545->1546; 1546->1547; 1547->1548; 1548->1549; 1549->1550; }

1539,1540

1550

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
805	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:22	2 s	20/20	175.6 KiB
804	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:21	0.5 s	20/20	217.9 KiB	175.6 KiB
803	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:21	0.2 s	20/20	79.4 KiB	167.1 KiB
802	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:21	0.2 s	20/20	43.6 KiB	50.7 KiB
801	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:21	0.2 s	1/1		43.6 KiB
800	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a 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 08:19:21	0.2 s	1/1		79.4 KiB

Page: