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

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

Enable zooming

digraph G { id="graph_172350"; subgraph graph_stage_172350 { id="graph_stage_172350"; isCluster="true"; label="Stage 172350"; subgraph cluster_1237405 { id="cluster_1237405"; isCluster="true"; label="Scan parquet "; 481243 [id="node_481243" labelType="html" label="FileScanRDD [481243] start at FileStorageAdapterImpl.java:179}"]; 481244 [id="node_481244" labelType="html" label="MapPartitionsRDD [481244] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237401 { id="cluster_1237401"; isCluster="true"; label="WholeStageCodegen (1)"; 481245 [id="node_481245" labelType="html" label="MapPartitionsRDD [481245] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237400 { id="cluster_1237400"; isCluster="true"; label="Exchange"; 481246 [id="node_481246" labelType="html" label="MapPartitionsRDD [481246] start at FileStorageAdapterImpl.java:179}"]; } } 481243->481244; 481244->481245; 481245->481246; }

digraph G { id="graph_172351"; subgraph graph_stage_172351 { id="graph_stage_172351"; isCluster="true"; label="Stage 172351"; subgraph cluster_1237438 { id="cluster_1237438"; isCluster="true"; label="Scan parquet "; 481254 [id="node_481254" labelType="html" label="FileScanRDD [481254] start at FileStorageAdapterImpl.java:179}"]; 481255 [id="node_481255" labelType="html" label="MapPartitionsRDD [481255] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237434 { id="cluster_1237434"; isCluster="true"; label="WholeStageCodegen (7)"; 481256 [id="node_481256" labelType="html" label="MapPartitionsRDD [481256] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237433 { id="cluster_1237433"; isCluster="true"; label="Exchange"; 481257 [id="node_481257" labelType="html" label="MapPartitionsRDD [481257] start at FileStorageAdapterImpl.java:179}"]; } } 481254->481255; 481255->481256; 481256->481257; }

digraph G { id="graph_172352"; subgraph graph_stage_172352 { id="graph_stage_172352"; isCluster="true"; label="Stage 172352"; subgraph cluster_1237433 { id="cluster_1237433"; isCluster="true"; label="Exchange"; 481258 [id="node_481258" labelType="html" label="ShuffledRowRDD [481258] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237418 { id="cluster_1237418"; isCluster="true"; label="WholeStageCodegen (11)"; 481259 [id="node_481259" labelType="html" label="MapPartitionsRDD [481259] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237417 { id="cluster_1237417"; isCluster="true"; label="Exchange"; 481260 [id="node_481260" labelType="html" label="MapPartitionsRDD [481260] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481258->481259; 481259->481260; }

481257,481258

digraph G { id="graph_172353"; subgraph graph_stage_172353 { id="graph_stage_172353"; isCluster="true"; label="Stage 172353"; subgraph cluster_1237400 { id="cluster_1237400"; isCluster="true"; label="Exchange"; 481247 [id="node_481247" labelType="html" label="ShuffledRowRDD [481247] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237379 { id="cluster_1237379"; isCluster="true"; label="WholeStageCodegen (5)"; 481248 [id="node_481248" labelType="html" label="MapPartitionsRDD [481248] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237378 { id="cluster_1237378"; isCluster="true"; label="Exchange"; 481249 [id="node_481249" labelType="html" label="MapPartitionsRDD [481249] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481247->481248; 481248->481249; }

481246,481247

digraph G { id="graph_172354"; subgraph graph_stage_172354 { id="graph_stage_172354"; isCluster="true"; label="Stage 172354"; subgraph cluster_1237378 { id="cluster_1237378"; isCluster="true"; label="Exchange"; 481250 [id="node_481250" labelType="html" label="ShuffledRowRDD [481250] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237375 { id="cluster_1237375"; isCluster="true"; label="WholeStageCodegen (6)"; 481251 [id="node_481251" labelType="html" label="MapPartitionsRDD [481251] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237417 { id="cluster_1237417"; isCluster="true"; label="Exchange"; 481261 [id="node_481261" labelType="html" label="ShuffledRowRDD [481261] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237414 { id="cluster_1237414"; isCluster="true"; label="WholeStageCodegen (12)"; 481262 [id="node_481262" labelType="html" label="MapPartitionsRDD [481262] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237371 { id="cluster_1237371"; isCluster="true"; label="WholeStageCodegen (13)"; 481263 [id="node_481263" labelType="html" label="ZippedPartitionsRDD2 [481263] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 481264 [id="node_481264" labelType="html" label="MapPartitionsRDD [481264] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237370 { id="cluster_1237370"; isCluster="true"; label="ObjectHashAggregate"; 481265 [id="node_481265" labelType="html" label="MapPartitionsRDD [481265] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237369 { id="cluster_1237369"; isCluster="true"; label="Exchange"; 481266 [id="node_481266" labelType="html" label="MapPartitionsRDD [481266] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481250->481251; 481261->481262; 481251->481263; 481262->481263; 481263->481264; 481264->481265; 481265->481266; }

481249,481250

481260,481261

digraph G { id="graph_172355"; subgraph graph_stage_172355 { id="graph_stage_172355"; isCluster="true"; label="Stage 172355"; 481275 [id="node_481275" labelType="html" label="SQLExecutionRDD [481275] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1237369 { id="cluster_1237369"; isCluster="true"; label="Exchange"; 481267 [id="node_481267" labelType="html" label="ShuffledRowRDD [481267] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237368 { id="cluster_1237368"; isCluster="true"; label="ObjectHashAggregate"; 481268 [id="node_481268" labelType="html" label="MapPartitionsRDD [481268] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237367 { id="cluster_1237367"; isCluster="true"; label="Project"; 481269 [id="node_481269" labelType="html" label="MapPartitionsRDD [481269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237360 { id="cluster_1237360"; isCluster="true"; label="WholeStageCodegen (16)"; 481270 [id="node_481270" labelType="html" label="MapPartitionsRDD [481270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237359 { id="cluster_1237359"; isCluster="true"; label="DeserializeToObject"; 481271 [id="node_481271" labelType="html" label="MapPartitionsRDD [481271] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237358 { id="cluster_1237358"; isCluster="true"; label="MapPartitions"; 481272 [id="node_481272" labelType="html" label="MapPartitionsRDD [481272] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237290 { id="cluster_1237290"; isCluster="true"; label="WholeStageCodegen (19)"; 481273 [id="node_481273" labelType="html" label="MapPartitionsRDD [481273] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237269 { id="cluster_1237269"; isCluster="true"; label="DeserializeToObject"; 481274 [id="node_481274" labelType="html" label="MapPartitionsRDD [481274] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237446 { id="cluster_1237446"; isCluster="true"; label="mapPartitions"; 481276 [id="node_481276" labelType="html" label="MapPartitionsRDD [481276] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237447 { id="cluster_1237447"; isCluster="true"; label="mapPartitions"; 481277 [id="node_481277" labelType="html" label="MapPartitionsRDD [481277] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481267->481268; 481268->481269; 481269->481270; 481270->481271; 481271->481272; 481272->481273; 481273->481274; 481274->481275; 481275->481276; 481276->481277; }

481266,481267

481277

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172355	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:29	3 s	30/30	204.6 KiB
172354	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:28	0.7 s	30/30	215.6 KiB	204.6 KiB
172353	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:28	0.2 s	30/30	1988.9 KiB	205.2 KiB
172352	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:28	0.4 s	30/30	152.9 KiB	10.4 KiB
172351	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:28	0.4 s	26/26		152.9 KiB
172350	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 90 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:53:28	0.4 s	26/26		1988.9 KiB

Page: