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

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

Enable zooming

digraph G { id="graph_318309"; subgraph graph_stage_318309 { id="graph_stage_318309"; isCluster="true"; label="Stage 318309"; subgraph cluster_2308584 { id="cluster_2308584"; isCluster="true"; label="Scan parquet "; 890648 [id="node_890648" labelType="html" label="FileScanRDD [890648] start at FileStorageAdapterImpl.java:174}"]; 890649 [id="node_890649" labelType="html" label="MapPartitionsRDD [890649] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308580 { id="cluster_2308580"; isCluster="true"; label="WholeStageCodegen (7)"; 890650 [id="node_890650" labelType="html" label="MapPartitionsRDD [890650] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308579 { id="cluster_2308579"; isCluster="true"; label="Exchange"; 890651 [id="node_890651" labelType="html" label="MapPartitionsRDD [890651] start at FileStorageAdapterImpl.java:174}"]; } } 890648->890649; 890649->890650; 890650->890651; }

digraph G { id="graph_318310"; subgraph graph_stage_318310 { id="graph_stage_318310"; isCluster="true"; label="Stage 318310"; subgraph cluster_2308558 { id="cluster_2308558"; isCluster="true"; label="Scan parquet "; 890637 [id="node_890637" labelType="html" label="FileScanRDD [890637] start at FileStorageAdapterImpl.java:174}"]; 890638 [id="node_890638" labelType="html" label="MapPartitionsRDD [890638] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308554 { id="cluster_2308554"; isCluster="true"; label="WholeStageCodegen (1)"; 890639 [id="node_890639" labelType="html" label="MapPartitionsRDD [890639] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308553 { id="cluster_2308553"; isCluster="true"; label="Exchange"; 890640 [id="node_890640" labelType="html" label="MapPartitionsRDD [890640] start at FileStorageAdapterImpl.java:174}"]; } } 890637->890638; 890638->890639; 890639->890640; }

digraph G { id="graph_318311"; subgraph graph_stage_318311 { id="graph_stage_318311"; isCluster="true"; label="Stage 318311"; subgraph cluster_2308553 { id="cluster_2308553"; isCluster="true"; label="Exchange"; 890641 [id="node_890641" labelType="html" label="ShuffledRowRDD [890641] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308541 { id="cluster_2308541"; isCluster="true"; label="WholeStageCodegen (5)"; 890642 [id="node_890642" labelType="html" label="MapPartitionsRDD [890642] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308540 { id="cluster_2308540"; isCluster="true"; label="Exchange"; 890643 [id="node_890643" labelType="html" label="MapPartitionsRDD [890643] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 890641->890642; 890642->890643; }

890640,890641

digraph G { id="graph_318312"; subgraph graph_stage_318312 { id="graph_stage_318312"; isCluster="true"; label="Stage 318312"; subgraph cluster_2308579 { id="cluster_2308579"; isCluster="true"; label="Exchange"; 890652 [id="node_890652" labelType="html" label="ShuffledRowRDD [890652] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308564 { id="cluster_2308564"; isCluster="true"; label="WholeStageCodegen (11)"; 890653 [id="node_890653" labelType="html" label="MapPartitionsRDD [890653] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308563 { id="cluster_2308563"; isCluster="true"; label="Exchange"; 890654 [id="node_890654" labelType="html" label="MapPartitionsRDD [890654] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 890652->890653; 890653->890654; }

890651,890652

digraph G { id="graph_318313"; subgraph graph_stage_318313 { id="graph_stage_318313"; isCluster="true"; label="Stage 318313"; subgraph cluster_2308540 { id="cluster_2308540"; isCluster="true"; label="Exchange"; 890644 [id="node_890644" labelType="html" label="ShuffledRowRDD [890644] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308537 { id="cluster_2308537"; isCluster="true"; label="WholeStageCodegen (6)"; 890645 [id="node_890645" labelType="html" label="MapPartitionsRDD [890645] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308563 { id="cluster_2308563"; isCluster="true"; label="Exchange"; 890655 [id="node_890655" labelType="html" label="ShuffledRowRDD [890655] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308560 { id="cluster_2308560"; isCluster="true"; label="WholeStageCodegen (12)"; 890656 [id="node_890656" labelType="html" label="MapPartitionsRDD [890656] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308533 { id="cluster_2308533"; isCluster="true"; label="WholeStageCodegen (13)"; 890657 [id="node_890657" labelType="html" label="ZippedPartitionsRDD2 [890657] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 890658 [id="node_890658" labelType="html" label="MapPartitionsRDD [890658] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308532 { id="cluster_2308532"; isCluster="true"; label="ObjectHashAggregate"; 890659 [id="node_890659" labelType="html" label="MapPartitionsRDD [890659] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308531 { id="cluster_2308531"; isCluster="true"; label="Exchange"; 890660 [id="node_890660" labelType="html" label="MapPartitionsRDD [890660] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 890644->890645; 890655->890656; 890645->890657; 890656->890657; 890657->890658; 890658->890659; 890659->890660; }

890643,890644

890654,890655

digraph G { id="graph_318314"; subgraph graph_stage_318314 { id="graph_stage_318314"; isCluster="true"; label="Stage 318314"; 890669 [id="node_890669" labelType="html" label="SQLExecutionRDD [890669] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2308531 { id="cluster_2308531"; isCluster="true"; label="Exchange"; 890661 [id="node_890661" labelType="html" label="ShuffledRowRDD [890661] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308530 { id="cluster_2308530"; isCluster="true"; label="ObjectHashAggregate"; 890662 [id="node_890662" labelType="html" label="MapPartitionsRDD [890662] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308529 { id="cluster_2308529"; isCluster="true"; label="Project"; 890663 [id="node_890663" labelType="html" label="MapPartitionsRDD [890663] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308515 { id="cluster_2308515"; isCluster="true"; label="WholeStageCodegen (16)"; 890664 [id="node_890664" labelType="html" label="MapPartitionsRDD [890664] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308514 { id="cluster_2308514"; isCluster="true"; label="DeserializeToObject"; 890665 [id="node_890665" labelType="html" label="MapPartitionsRDD [890665] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308513 { id="cluster_2308513"; isCluster="true"; label="MapPartitions"; 890666 [id="node_890666" labelType="html" label="MapPartitionsRDD [890666] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308436 { id="cluster_2308436"; isCluster="true"; label="WholeStageCodegen (19)"; 890667 [id="node_890667" labelType="html" label="MapPartitionsRDD [890667] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308415 { id="cluster_2308415"; isCluster="true"; label="DeserializeToObject"; 890668 [id="node_890668" labelType="html" label="MapPartitionsRDD [890668] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308592 { id="cluster_2308592"; isCluster="true"; label="mapPartitions"; 890670 [id="node_890670" labelType="html" label="MapPartitionsRDD [890670] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2308593 { id="cluster_2308593"; isCluster="true"; label="mapPartitions"; 890671 [id="node_890671" labelType="html" label="MapPartitionsRDD [890671] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 890661->890662; 890662->890663; 890663->890664; 890664->890665; 890665->890666; 890666->890667; 890667->890668; 890668->890669; 890669->890670; 890670->890671; }

890660,890661

890671

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
318314	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:07	1 s	30/30	12.9 KiB
318313	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:06	0.8 s	30/30	26.9 KiB	12.9 KiB
318312	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:05	0.4 s	30/30	2.3 KiB	3.1 KiB
318311	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:05	0.3 s	30/30	5.3 KiB	23.9 KiB
318310	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:05	0.3 s	1/1		5.3 KiB
318309	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 25 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:46:05	0.3 s	1/1		2.3 KiB

Page: