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

Status: SUCCEEDED
Submitted: 2026/07/21 20:56:43
Duration: 4 s
Associated SQL Query: 38666
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 6

Enable zooming

digraph G { id="graph_172881"; subgraph graph_stage_172881 { id="graph_stage_172881"; isCluster="true"; label="Stage 172881"; subgraph cluster_1241173 { id="cluster_1241173"; isCluster="true"; label="Scan parquet "; 482778 [id="node_482778" labelType="html" label="FileScanRDD [482778] start at FileStorageAdapterImpl.java:179}"]; 482779 [id="node_482779" labelType="html" label="MapPartitionsRDD [482779] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241169 { id="cluster_1241169"; isCluster="true"; label="WholeStageCodegen (7)"; 482780 [id="node_482780" labelType="html" label="MapPartitionsRDD [482780] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241168 { id="cluster_1241168"; isCluster="true"; label="Exchange"; 482781 [id="node_482781" labelType="html" label="MapPartitionsRDD [482781] start at FileStorageAdapterImpl.java:179}"]; } } 482778->482779; 482779->482780; 482780->482781; }

digraph G { id="graph_172882"; subgraph graph_stage_172882 { id="graph_stage_172882"; isCluster="true"; label="Stage 172882"; subgraph cluster_1241147 { id="cluster_1241147"; isCluster="true"; label="Scan parquet "; 482767 [id="node_482767" labelType="html" label="FileScanRDD [482767] start at FileStorageAdapterImpl.java:179}"]; 482768 [id="node_482768" labelType="html" label="MapPartitionsRDD [482768] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241143 { id="cluster_1241143"; isCluster="true"; label="WholeStageCodegen (1)"; 482769 [id="node_482769" labelType="html" label="MapPartitionsRDD [482769] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241142 { id="cluster_1241142"; isCluster="true"; label="Exchange"; 482770 [id="node_482770" labelType="html" label="MapPartitionsRDD [482770] start at FileStorageAdapterImpl.java:179}"]; } } 482767->482768; 482768->482769; 482769->482770; }

digraph G { id="graph_172883"; subgraph graph_stage_172883 { id="graph_stage_172883"; isCluster="true"; label="Stage 172883"; subgraph cluster_1241142 { id="cluster_1241142"; isCluster="true"; label="Exchange"; 482771 [id="node_482771" labelType="html" label="ShuffledRowRDD [482771] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241114 { id="cluster_1241114"; isCluster="true"; label="WholeStageCodegen (5)"; 482772 [id="node_482772" labelType="html" label="MapPartitionsRDD [482772] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241113 { id="cluster_1241113"; isCluster="true"; label="Exchange"; 482773 [id="node_482773" labelType="html" label="MapPartitionsRDD [482773] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482771->482772; 482772->482773; }

482770,482771

digraph G { id="graph_172884"; subgraph graph_stage_172884 { id="graph_stage_172884"; isCluster="true"; label="Stage 172884"; subgraph cluster_1241168 { id="cluster_1241168"; isCluster="true"; label="Exchange"; 482782 [id="node_482782" labelType="html" label="ShuffledRowRDD [482782] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241153 { id="cluster_1241153"; isCluster="true"; label="WholeStageCodegen (11)"; 482783 [id="node_482783" labelType="html" label="MapPartitionsRDD [482783] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241152 { id="cluster_1241152"; isCluster="true"; label="Exchange"; 482784 [id="node_482784" labelType="html" label="MapPartitionsRDD [482784] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482782->482783; 482783->482784; }

482781,482782

digraph G { id="graph_172885"; subgraph graph_stage_172885 { id="graph_stage_172885"; isCluster="true"; label="Stage 172885"; subgraph cluster_1241113 { id="cluster_1241113"; isCluster="true"; label="Exchange"; 482774 [id="node_482774" labelType="html" label="ShuffledRowRDD [482774] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241110 { id="cluster_1241110"; isCluster="true"; label="WholeStageCodegen (6)"; 482775 [id="node_482775" labelType="html" label="MapPartitionsRDD [482775] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241152 { id="cluster_1241152"; isCluster="true"; label="Exchange"; 482785 [id="node_482785" labelType="html" label="ShuffledRowRDD [482785] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241149 { id="cluster_1241149"; isCluster="true"; label="WholeStageCodegen (12)"; 482786 [id="node_482786" labelType="html" label="MapPartitionsRDD [482786] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241106 { id="cluster_1241106"; isCluster="true"; label="WholeStageCodegen (13)"; 482787 [id="node_482787" labelType="html" label="ZippedPartitionsRDD2 [482787] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 482788 [id="node_482788" labelType="html" label="MapPartitionsRDD [482788] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241105 { id="cluster_1241105"; isCluster="true"; label="ObjectHashAggregate"; 482789 [id="node_482789" labelType="html" label="MapPartitionsRDD [482789] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241104 { id="cluster_1241104"; isCluster="true"; label="Exchange"; 482790 [id="node_482790" labelType="html" label="MapPartitionsRDD [482790] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482774->482775; 482785->482786; 482775->482787; 482786->482787; 482787->482788; 482788->482789; 482789->482790; }

482773,482774

482784,482785

digraph G { id="graph_172886"; subgraph graph_stage_172886 { id="graph_stage_172886"; isCluster="true"; label="Stage 172886"; 482799 [id="node_482799" labelType="html" label="SQLExecutionRDD [482799] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1241104 { id="cluster_1241104"; isCluster="true"; label="Exchange"; 482791 [id="node_482791" labelType="html" label="ShuffledRowRDD [482791] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241103 { id="cluster_1241103"; isCluster="true"; label="ObjectHashAggregate"; 482792 [id="node_482792" labelType="html" label="MapPartitionsRDD [482792] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241102 { id="cluster_1241102"; isCluster="true"; label="Project"; 482793 [id="node_482793" labelType="html" label="MapPartitionsRDD [482793] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241081 { id="cluster_1241081"; isCluster="true"; label="WholeStageCodegen (16)"; 482794 [id="node_482794" labelType="html" label="MapPartitionsRDD [482794] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241080 { id="cluster_1241080"; isCluster="true"; label="DeserializeToObject"; 482795 [id="node_482795" labelType="html" label="MapPartitionsRDD [482795] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241079 { id="cluster_1241079"; isCluster="true"; label="MapPartitions"; 482796 [id="node_482796" labelType="html" label="MapPartitionsRDD [482796] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241034 { id="cluster_1241034"; isCluster="true"; label="WholeStageCodegen (19)"; 482797 [id="node_482797" labelType="html" label="MapPartitionsRDD [482797] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241004 { id="cluster_1241004"; isCluster="true"; label="DeserializeToObject"; 482798 [id="node_482798" labelType="html" label="MapPartitionsRDD [482798] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241181 { id="cluster_1241181"; isCluster="true"; label="mapPartitions"; 482800 [id="node_482800" labelType="html" label="MapPartitionsRDD [482800] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1241182 { id="cluster_1241182"; isCluster="true"; label="mapPartitions"; 482801 [id="node_482801" labelType="html" label="MapPartitionsRDD [482801] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 482791->482792; 482792->482793; 482793->482794; 482794->482795; 482795->482796; 482796->482797; 482797->482798; 482798->482799; 482799->482800; 482800->482801; }

482790,482791

482801

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172886	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:45	2 s	30/30	43.1 KiB
172885	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:44	2 s	30/30	92.2 KiB	43.1 KiB
172884	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:44	0.2 s	30/30	152.9 KiB	1960.0 B
172883	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:44	0.2 s	30/30	1988.9 KiB	90.3 KiB
172882	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:43	0.5 s	26/26		1988.9 KiB
172881	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 97 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:56:43	0.4 s	26/26		152.9 KiB

Page: