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

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

Enable zooming

digraph G { id="graph_878"; subgraph graph_stage_878 { id="graph_stage_878"; isCluster="true"; label="Stage 878"; subgraph cluster_4394 { id="cluster_4394"; isCluster="true"; label="Scan parquet "; 1751 [id="node_1751" labelType="html" label="FileScanRDD [1751] start at FileStorageAdapterImpl.java:177}"]; 1752 [id="node_1752" labelType="html" label="MapPartitionsRDD [1752] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4390 { id="cluster_4390"; isCluster="true"; label="WholeStageCodegen (1)"; 1753 [id="node_1753" labelType="html" label="MapPartitionsRDD [1753] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4389 { id="cluster_4389"; isCluster="true"; label="Exchange"; 1754 [id="node_1754" labelType="html" label="MapPartitionsRDD [1754] start at FileStorageAdapterImpl.java:177}"]; } } 1751->1752; 1752->1753; 1753->1754; }

digraph G { id="graph_879"; subgraph graph_stage_879 { id="graph_stage_879"; isCluster="true"; label="Stage 879"; subgraph cluster_4427 { id="cluster_4427"; isCluster="true"; label="Scan parquet "; 1762 [id="node_1762" labelType="html" label="FileScanRDD [1762] start at FileStorageAdapterImpl.java:177}"]; 1763 [id="node_1763" labelType="html" label="MapPartitionsRDD [1763] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4423 { id="cluster_4423"; isCluster="true"; label="WholeStageCodegen (7)"; 1764 [id="node_1764" labelType="html" label="MapPartitionsRDD [1764] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4422 { id="cluster_4422"; isCluster="true"; label="Exchange"; 1765 [id="node_1765" labelType="html" label="MapPartitionsRDD [1765] start at FileStorageAdapterImpl.java:177}"]; } } 1762->1763; 1763->1764; 1764->1765; }

digraph G { id="graph_880"; subgraph graph_stage_880 { id="graph_stage_880"; isCluster="true"; label="Stage 880"; subgraph cluster_4422 { id="cluster_4422"; isCluster="true"; label="Exchange"; 1766 [id="node_1766" labelType="html" label="ShuffledRowRDD [1766] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4400 { id="cluster_4400"; isCluster="true"; label="WholeStageCodegen (11)"; 1767 [id="node_1767" labelType="html" label="MapPartitionsRDD [1767] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4399 { id="cluster_4399"; isCluster="true"; label="Exchange"; 1768 [id="node_1768" labelType="html" label="MapPartitionsRDD [1768] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1766->1767; 1767->1768; }

1765,1766

digraph G { id="graph_881"; subgraph graph_stage_881 { id="graph_stage_881"; isCluster="true"; label="Stage 881"; subgraph cluster_4389 { id="cluster_4389"; isCluster="true"; label="Exchange"; 1755 [id="node_1755" labelType="html" label="ShuffledRowRDD [1755] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4368 { id="cluster_4368"; isCluster="true"; label="WholeStageCodegen (5)"; 1756 [id="node_1756" labelType="html" label="MapPartitionsRDD [1756] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4367 { id="cluster_4367"; isCluster="true"; label="Exchange"; 1757 [id="node_1757" labelType="html" label="MapPartitionsRDD [1757] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1755->1756; 1756->1757; }

1754,1755

digraph G { id="graph_882"; subgraph graph_stage_882 { id="graph_stage_882"; isCluster="true"; label="Stage 882"; subgraph cluster_4367 { id="cluster_4367"; isCluster="true"; label="Exchange"; 1758 [id="node_1758" labelType="html" label="ShuffledRowRDD [1758] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4364 { id="cluster_4364"; isCluster="true"; label="WholeStageCodegen (6)"; 1759 [id="node_1759" labelType="html" label="MapPartitionsRDD [1759] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4399 { id="cluster_4399"; isCluster="true"; label="Exchange"; 1769 [id="node_1769" labelType="html" label="ShuffledRowRDD [1769] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4396 { id="cluster_4396"; isCluster="true"; label="WholeStageCodegen (12)"; 1770 [id="node_1770" labelType="html" label="MapPartitionsRDD [1770] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4360 { id="cluster_4360"; isCluster="true"; label="WholeStageCodegen (13)"; 1771 [id="node_1771" labelType="html" label="ZippedPartitionsRDD2 [1771] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1772 [id="node_1772" labelType="html" label="MapPartitionsRDD [1772] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4359 { id="cluster_4359"; isCluster="true"; label="ObjectHashAggregate"; 1773 [id="node_1773" labelType="html" label="MapPartitionsRDD [1773] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4358 { id="cluster_4358"; isCluster="true"; label="Exchange"; 1774 [id="node_1774" labelType="html" label="MapPartitionsRDD [1774] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1758->1759; 1769->1770; 1759->1771; 1770->1771; 1771->1772; 1772->1773; 1773->1774; }

1757,1758

1768,1769

digraph G { id="graph_883"; subgraph graph_stage_883 { id="graph_stage_883"; isCluster="true"; label="Stage 883"; 1783 [id="node_1783" labelType="html" label="SQLExecutionRDD [1783] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_4358 { id="cluster_4358"; isCluster="true"; label="Exchange"; 1775 [id="node_1775" labelType="html" label="ShuffledRowRDD [1775] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4357 { id="cluster_4357"; isCluster="true"; label="ObjectHashAggregate"; 1776 [id="node_1776" labelType="html" label="MapPartitionsRDD [1776] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4356 { id="cluster_4356"; isCluster="true"; label="Project"; 1777 [id="node_1777" labelType="html" label="MapPartitionsRDD [1777] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4349 { id="cluster_4349"; isCluster="true"; label="WholeStageCodegen (16)"; 1778 [id="node_1778" labelType="html" label="MapPartitionsRDD [1778] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4348 { id="cluster_4348"; isCluster="true"; label="DeserializeToObject"; 1779 [id="node_1779" labelType="html" label="MapPartitionsRDD [1779] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4347 { id="cluster_4347"; isCluster="true"; label="MapPartitions"; 1780 [id="node_1780" labelType="html" label="MapPartitionsRDD [1780] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4279 { id="cluster_4279"; isCluster="true"; label="WholeStageCodegen (19)"; 1781 [id="node_1781" labelType="html" label="MapPartitionsRDD [1781] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4258 { id="cluster_4258"; isCluster="true"; label="DeserializeToObject"; 1782 [id="node_1782" labelType="html" label="MapPartitionsRDD [1782] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4435 { id="cluster_4435"; isCluster="true"; label="mapPartitions"; 1784 [id="node_1784" labelType="html" label="MapPartitionsRDD [1784] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4436 { id="cluster_4436"; isCluster="true"; label="mapPartitions"; 1785 [id="node_1785" labelType="html" label="MapPartitionsRDD [1785] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1775->1776; 1776->1777; 1777->1778; 1778->1779; 1779->1780; 1780->1781; 1781->1782; 1782->1783; 1783->1784; 1784->1785; }

1774,1775

1785

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
883	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:34	2 s	20/20	593.8 KiB
882	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:33	0.4 s	20/20	779.9 KiB	593.8 KiB
881	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:33	0.1 s	20/20	79.4 KiB	587.1 KiB
880	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:33	0.1 s	20/20	43.6 KiB	192.8 KiB
879	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:33	0.2 s	1/1		43.6 KiB
878	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:20:33	0.2 s	1/1		79.4 KiB

Page: