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

Status: SUCCEEDED
Submitted: 2026/05/22 09:54:10
Duration: 2 s
Associated SQL Query: 73069
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 6

Enable zooming

digraph G { id="graph_319298"; subgraph graph_stage_319298 { id="graph_stage_319298"; isCluster="true"; label="Stage 319298"; subgraph cluster_2315579 { id="cluster_2315579"; isCluster="true"; label="Scan parquet "; 893503 [id="node_893503" labelType="html" label="FileScanRDD [893503] start at FileStorageAdapterImpl.java:174}"]; 893504 [id="node_893504" labelType="html" label="MapPartitionsRDD [893504] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315575 { id="cluster_2315575"; isCluster="true"; label="WholeStageCodegen (1)"; 893505 [id="node_893505" labelType="html" label="MapPartitionsRDD [893505] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315574 { id="cluster_2315574"; isCluster="true"; label="Exchange"; 893506 [id="node_893506" labelType="html" label="MapPartitionsRDD [893506] start at FileStorageAdapterImpl.java:174}"]; } } 893503->893504; 893504->893505; 893505->893506; }

digraph G { id="graph_319299"; subgraph graph_stage_319299 { id="graph_stage_319299"; isCluster="true"; label="Stage 319299"; subgraph cluster_2315605 { id="cluster_2315605"; isCluster="true"; label="Scan parquet "; 893514 [id="node_893514" labelType="html" label="FileScanRDD [893514] start at FileStorageAdapterImpl.java:174}"]; 893515 [id="node_893515" labelType="html" label="MapPartitionsRDD [893515] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315601 { id="cluster_2315601"; isCluster="true"; label="WholeStageCodegen (7)"; 893516 [id="node_893516" labelType="html" label="MapPartitionsRDD [893516] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315600 { id="cluster_2315600"; isCluster="true"; label="Exchange"; 893517 [id="node_893517" labelType="html" label="MapPartitionsRDD [893517] start at FileStorageAdapterImpl.java:174}"]; } } 893514->893515; 893515->893516; 893516->893517; }

digraph G { id="graph_319300"; subgraph graph_stage_319300 { id="graph_stage_319300"; isCluster="true"; label="Stage 319300"; subgraph cluster_2315600 { id="cluster_2315600"; isCluster="true"; label="Exchange"; 893518 [id="node_893518" labelType="html" label="ShuffledRowRDD [893518] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315585 { id="cluster_2315585"; isCluster="true"; label="WholeStageCodegen (11)"; 893519 [id="node_893519" labelType="html" label="MapPartitionsRDD [893519] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315584 { id="cluster_2315584"; isCluster="true"; label="Exchange"; 893520 [id="node_893520" labelType="html" label="MapPartitionsRDD [893520] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893518->893519; 893519->893520; }

893517,893518

digraph G { id="graph_319301"; subgraph graph_stage_319301 { id="graph_stage_319301"; isCluster="true"; label="Stage 319301"; subgraph cluster_2315574 { id="cluster_2315574"; isCluster="true"; label="Exchange"; 893507 [id="node_893507" labelType="html" label="ShuffledRowRDD [893507] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315546 { id="cluster_2315546"; isCluster="true"; label="WholeStageCodegen (5)"; 893508 [id="node_893508" labelType="html" label="MapPartitionsRDD [893508] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315545 { id="cluster_2315545"; isCluster="true"; label="Exchange"; 893509 [id="node_893509" labelType="html" label="MapPartitionsRDD [893509] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893507->893508; 893508->893509; }

893506,893507

digraph G { id="graph_319302"; subgraph graph_stage_319302 { id="graph_stage_319302"; isCluster="true"; label="Stage 319302"; subgraph cluster_2315545 { id="cluster_2315545"; isCluster="true"; label="Exchange"; 893510 [id="node_893510" labelType="html" label="ShuffledRowRDD [893510] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315542 { id="cluster_2315542"; isCluster="true"; label="WholeStageCodegen (6)"; 893511 [id="node_893511" labelType="html" label="MapPartitionsRDD [893511] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315584 { id="cluster_2315584"; isCluster="true"; label="Exchange"; 893521 [id="node_893521" labelType="html" label="ShuffledRowRDD [893521] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315581 { id="cluster_2315581"; isCluster="true"; label="WholeStageCodegen (12)"; 893522 [id="node_893522" labelType="html" label="MapPartitionsRDD [893522] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315538 { id="cluster_2315538"; isCluster="true"; label="WholeStageCodegen (13)"; 893523 [id="node_893523" labelType="html" label="ZippedPartitionsRDD2 [893523] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893524 [id="node_893524" labelType="html" label="MapPartitionsRDD [893524] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315537 { id="cluster_2315537"; isCluster="true"; label="ObjectHashAggregate"; 893525 [id="node_893525" labelType="html" label="MapPartitionsRDD [893525] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315536 { id="cluster_2315536"; isCluster="true"; label="Exchange"; 893526 [id="node_893526" labelType="html" label="MapPartitionsRDD [893526] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893510->893511; 893521->893522; 893511->893523; 893522->893523; 893523->893524; 893524->893525; 893525->893526; }

893509,893510

893520,893521

digraph G { id="graph_319303"; subgraph graph_stage_319303 { id="graph_stage_319303"; isCluster="true"; label="Stage 319303"; 893535 [id="node_893535" labelType="html" label="SQLExecutionRDD [893535] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2315536 { id="cluster_2315536"; isCluster="true"; label="Exchange"; 893527 [id="node_893527" labelType="html" label="ShuffledRowRDD [893527] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315535 { id="cluster_2315535"; isCluster="true"; label="ObjectHashAggregate"; 893528 [id="node_893528" labelType="html" label="MapPartitionsRDD [893528] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315534 { id="cluster_2315534"; isCluster="true"; label="Project"; 893529 [id="node_893529" labelType="html" label="MapPartitionsRDD [893529] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315513 { id="cluster_2315513"; isCluster="true"; label="WholeStageCodegen (16)"; 893530 [id="node_893530" labelType="html" label="MapPartitionsRDD [893530] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315512 { id="cluster_2315512"; isCluster="true"; label="DeserializeToObject"; 893531 [id="node_893531" labelType="html" label="MapPartitionsRDD [893531] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315511 { id="cluster_2315511"; isCluster="true"; label="MapPartitions"; 893532 [id="node_893532" labelType="html" label="MapPartitionsRDD [893532] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315458 { id="cluster_2315458"; isCluster="true"; label="WholeStageCodegen (19)"; 893533 [id="node_893533" labelType="html" label="MapPartitionsRDD [893533] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315436 { id="cluster_2315436"; isCluster="true"; label="DeserializeToObject"; 893534 [id="node_893534" labelType="html" label="MapPartitionsRDD [893534] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315613 { id="cluster_2315613"; isCluster="true"; label="mapPartitions"; 893536 [id="node_893536" labelType="html" label="MapPartitionsRDD [893536] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315614 { id="cluster_2315614"; isCluster="true"; label="mapPartitions"; 893537 [id="node_893537" labelType="html" label="MapPartitionsRDD [893537] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893527->893528; 893528->893529; 893529->893530; 893530->893531; 893531->893532; 893532->893533; 893533->893534; 893534->893535; 893535->893536; 893536->893537; }

893526,893527

893537

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
319303	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:11	0.7 s	30/30	3.3 KiB
319302	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:10	0.7 s	30/30	4.0 KiB	3.3 KiB
319301	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:10	0.2 s	30/30	5.3 KiB	3.2 KiB
319300	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:10	0.4 s	30/30	2.3 KiB	784.0 B
319299	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:10	0.3 s	1/1		2.3 KiB
319298	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 38 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:10	0.3 s	1/1		5.3 KiB

Page: