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

Status: SUCCEEDED
Submitted: 2026/06/09 15:54:20
Duration: 2 s
Associated SQL Query: 100512
Job Group: 6ced03eb-c046-4d38-8b3d-6156b8f3929b
Completed Stages: 6

Enable zooming

digraph G { id="graph_446358"; subgraph graph_stage_446358 { id="graph_stage_446358"; isCluster="true"; label="Stage 446358"; subgraph cluster_3152720 { id="cluster_3152720"; isCluster="true"; label="Scan parquet "; 1243632 [id="node_1243632" labelType="html" label="FileScanRDD [1243632] start at FileStorageAdapterImpl.java:174}"]; 1243633 [id="node_1243633" labelType="html" label="MapPartitionsRDD [1243633] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152716 { id="cluster_3152716"; isCluster="true"; label="WholeStageCodegen (1)"; 1243634 [id="node_1243634" labelType="html" label="MapPartitionsRDD [1243634] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152715 { id="cluster_3152715"; isCluster="true"; label="Exchange"; 1243635 [id="node_1243635" labelType="html" label="MapPartitionsRDD [1243635] start at FileStorageAdapterImpl.java:174}"]; } } 1243632->1243633; 1243633->1243634; 1243634->1243635; }

digraph G { id="graph_446359"; subgraph graph_stage_446359 { id="graph_stage_446359"; isCluster="true"; label="Stage 446359"; subgraph cluster_3152753 { id="cluster_3152753"; isCluster="true"; label="Scan parquet "; 1243643 [id="node_1243643" labelType="html" label="FileScanRDD [1243643] start at FileStorageAdapterImpl.java:174}"]; 1243644 [id="node_1243644" labelType="html" label="MapPartitionsRDD [1243644] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152749 { id="cluster_3152749"; isCluster="true"; label="WholeStageCodegen (7)"; 1243645 [id="node_1243645" labelType="html" label="MapPartitionsRDD [1243645] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152748 { id="cluster_3152748"; isCluster="true"; label="Exchange"; 1243646 [id="node_1243646" labelType="html" label="MapPartitionsRDD [1243646] start at FileStorageAdapterImpl.java:174}"]; } } 1243643->1243644; 1243644->1243645; 1243645->1243646; }

digraph G { id="graph_446360"; subgraph graph_stage_446360 { id="graph_stage_446360"; isCluster="true"; label="Stage 446360"; subgraph cluster_3152748 { id="cluster_3152748"; isCluster="true"; label="Exchange"; 1243647 [id="node_1243647" labelType="html" label="ShuffledRowRDD [1243647] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152726 { id="cluster_3152726"; isCluster="true"; label="WholeStageCodegen (11)"; 1243648 [id="node_1243648" labelType="html" label="MapPartitionsRDD [1243648] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152725 { id="cluster_3152725"; isCluster="true"; label="Exchange"; 1243649 [id="node_1243649" labelType="html" label="MapPartitionsRDD [1243649] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243647->1243648; 1243648->1243649; }

1243646,1243647

digraph G { id="graph_446361"; subgraph graph_stage_446361 { id="graph_stage_446361"; isCluster="true"; label="Stage 446361"; subgraph cluster_3152715 { id="cluster_3152715"; isCluster="true"; label="Exchange"; 1243636 [id="node_1243636" labelType="html" label="ShuffledRowRDD [1243636] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152694 { id="cluster_3152694"; isCluster="true"; label="WholeStageCodegen (5)"; 1243637 [id="node_1243637" labelType="html" label="MapPartitionsRDD [1243637] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152693 { id="cluster_3152693"; isCluster="true"; label="Exchange"; 1243638 [id="node_1243638" labelType="html" label="MapPartitionsRDD [1243638] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243636->1243637; 1243637->1243638; }

1243635,1243636

digraph G { id="graph_446362"; subgraph graph_stage_446362 { id="graph_stage_446362"; isCluster="true"; label="Stage 446362"; subgraph cluster_3152693 { id="cluster_3152693"; isCluster="true"; label="Exchange"; 1243639 [id="node_1243639" labelType="html" label="ShuffledRowRDD [1243639] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152690 { id="cluster_3152690"; isCluster="true"; label="WholeStageCodegen (6)"; 1243640 [id="node_1243640" labelType="html" label="MapPartitionsRDD [1243640] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152725 { id="cluster_3152725"; isCluster="true"; label="Exchange"; 1243650 [id="node_1243650" labelType="html" label="ShuffledRowRDD [1243650] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152722 { id="cluster_3152722"; isCluster="true"; label="WholeStageCodegen (12)"; 1243651 [id="node_1243651" labelType="html" label="MapPartitionsRDD [1243651] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152686 { id="cluster_3152686"; isCluster="true"; label="WholeStageCodegen (13)"; 1243652 [id="node_1243652" labelType="html" label="ZippedPartitionsRDD2 [1243652] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243653 [id="node_1243653" labelType="html" label="MapPartitionsRDD [1243653] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152685 { id="cluster_3152685"; isCluster="true"; label="ObjectHashAggregate"; 1243654 [id="node_1243654" labelType="html" label="MapPartitionsRDD [1243654] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152684 { id="cluster_3152684"; isCluster="true"; label="Exchange"; 1243655 [id="node_1243655" labelType="html" label="MapPartitionsRDD [1243655] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243639->1243640; 1243650->1243651; 1243640->1243652; 1243651->1243652; 1243652->1243653; 1243653->1243654; 1243654->1243655; }

1243638,1243639

1243649,1243650

digraph G { id="graph_446363"; subgraph graph_stage_446363 { id="graph_stage_446363"; isCluster="true"; label="Stage 446363"; 1243664 [id="node_1243664" labelType="html" label="SQLExecutionRDD [1243664] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152684 { id="cluster_3152684"; isCluster="true"; label="Exchange"; 1243656 [id="node_1243656" labelType="html" label="ShuffledRowRDD [1243656] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152683 { id="cluster_3152683"; isCluster="true"; label="ObjectHashAggregate"; 1243657 [id="node_1243657" labelType="html" label="MapPartitionsRDD [1243657] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152682 { id="cluster_3152682"; isCluster="true"; label="Project"; 1243658 [id="node_1243658" labelType="html" label="MapPartitionsRDD [1243658] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152675 { id="cluster_3152675"; isCluster="true"; label="WholeStageCodegen (16)"; 1243659 [id="node_1243659" labelType="html" label="MapPartitionsRDD [1243659] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152674 { id="cluster_3152674"; isCluster="true"; label="DeserializeToObject"; 1243660 [id="node_1243660" labelType="html" label="MapPartitionsRDD [1243660] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152673 { id="cluster_3152673"; isCluster="true"; label="MapPartitions"; 1243661 [id="node_1243661" labelType="html" label="MapPartitionsRDD [1243661] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152602 { id="cluster_3152602"; isCluster="true"; label="WholeStageCodegen (19)"; 1243662 [id="node_1243662" labelType="html" label="MapPartitionsRDD [1243662] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152584 { id="cluster_3152584"; isCluster="true"; label="DeserializeToObject"; 1243663 [id="node_1243663" labelType="html" label="MapPartitionsRDD [1243663] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152761 { id="cluster_3152761"; isCluster="true"; label="mapPartitions"; 1243665 [id="node_1243665" labelType="html" label="MapPartitionsRDD [1243665] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152762 { id="cluster_3152762"; isCluster="true"; label="mapPartitions"; 1243666 [id="node_1243666" labelType="html" label="MapPartitionsRDD [1243666] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243656->1243657; 1243657->1243658; 1243658->1243659; 1243659->1243660; 1243660->1243661; 1243661->1243662; 1243662->1243663; 1243663->1243664; 1243664->1243665; 1243665->1243666; }

1243655,1243656

1243666

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
446363	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:21	1.0 s	20/20	9.8 KiB
446362	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:20	0.4 s	20/20	12.3 KiB	9.8 KiB
446361	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:20	0.1 s	20/20	13.5 KiB	9.3 KiB
446360	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:20	0.2 s	20/20	8.1 KiB	2.9 KiB
446359	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:20	0.2 s	1/1		8.1 KiB
446358	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 8 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.GeneratedMethodAccessor888.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/06/09 15:54:20	0.2 s	1/1		13.5 KiB

Page: