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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:45
Duration: 2 s
Associated SQL Query: 6511
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 6

Enable zooming

digraph G { id="graph_27778"; subgraph graph_stage_27778 { id="graph_stage_27778"; isCluster="true"; label="Stage 27778"; subgraph cluster_205737 { id="cluster_205737"; isCluster="true"; label="Scan parquet "; 78034 [id="node_78034" labelType="html" label="FileScanRDD [78034] start at FileStorageAdapterImpl.java:179}"]; 78035 [id="node_78035" labelType="html" label="MapPartitionsRDD [78035] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205733 { id="cluster_205733"; isCluster="true"; label="WholeStageCodegen (1)"; 78036 [id="node_78036" labelType="html" label="MapPartitionsRDD [78036] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205732 { id="cluster_205732"; isCluster="true"; label="Exchange"; 78037 [id="node_78037" labelType="html" label="MapPartitionsRDD [78037] start at FileStorageAdapterImpl.java:179}"]; } } 78034->78035; 78035->78036; 78036->78037; }

digraph G { id="graph_27779"; subgraph graph_stage_27779 { id="graph_stage_27779"; isCluster="true"; label="Stage 27779"; subgraph cluster_205770 { id="cluster_205770"; isCluster="true"; label="Scan parquet "; 78045 [id="node_78045" labelType="html" label="FileScanRDD [78045] start at FileStorageAdapterImpl.java:179}"]; 78046 [id="node_78046" labelType="html" label="MapPartitionsRDD [78046] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205766 { id="cluster_205766"; isCluster="true"; label="WholeStageCodegen (7)"; 78047 [id="node_78047" labelType="html" label="MapPartitionsRDD [78047] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205765 { id="cluster_205765"; isCluster="true"; label="Exchange"; 78048 [id="node_78048" labelType="html" label="MapPartitionsRDD [78048] start at FileStorageAdapterImpl.java:179}"]; } } 78045->78046; 78046->78047; 78047->78048; }

digraph G { id="graph_27780"; subgraph graph_stage_27780 { id="graph_stage_27780"; isCluster="true"; label="Stage 27780"; subgraph cluster_205765 { id="cluster_205765"; isCluster="true"; label="Exchange"; 78049 [id="node_78049" labelType="html" label="ShuffledRowRDD [78049] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205743 { id="cluster_205743"; isCluster="true"; label="WholeStageCodegen (11)"; 78050 [id="node_78050" labelType="html" label="MapPartitionsRDD [78050] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205742 { id="cluster_205742"; isCluster="true"; label="Exchange"; 78051 [id="node_78051" labelType="html" label="MapPartitionsRDD [78051] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78049->78050; 78050->78051; }

78048,78049

digraph G { id="graph_27781"; subgraph graph_stage_27781 { id="graph_stage_27781"; isCluster="true"; label="Stage 27781"; subgraph cluster_205732 { id="cluster_205732"; isCluster="true"; label="Exchange"; 78038 [id="node_78038" labelType="html" label="ShuffledRowRDD [78038] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205711 { id="cluster_205711"; isCluster="true"; label="WholeStageCodegen (5)"; 78039 [id="node_78039" labelType="html" label="MapPartitionsRDD [78039] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205710 { id="cluster_205710"; isCluster="true"; label="Exchange"; 78040 [id="node_78040" labelType="html" label="MapPartitionsRDD [78040] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78038->78039; 78039->78040; }

78037,78038

digraph G { id="graph_27782"; subgraph graph_stage_27782 { id="graph_stage_27782"; isCluster="true"; label="Stage 27782"; subgraph cluster_205710 { id="cluster_205710"; isCluster="true"; label="Exchange"; 78041 [id="node_78041" labelType="html" label="ShuffledRowRDD [78041] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205707 { id="cluster_205707"; isCluster="true"; label="WholeStageCodegen (6)"; 78042 [id="node_78042" labelType="html" label="MapPartitionsRDD [78042] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205742 { id="cluster_205742"; isCluster="true"; label="Exchange"; 78052 [id="node_78052" labelType="html" label="ShuffledRowRDD [78052] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205739 { id="cluster_205739"; isCluster="true"; label="WholeStageCodegen (12)"; 78053 [id="node_78053" labelType="html" label="MapPartitionsRDD [78053] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205703 { id="cluster_205703"; isCluster="true"; label="WholeStageCodegen (13)"; 78054 [id="node_78054" labelType="html" label="ZippedPartitionsRDD2 [78054] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78055 [id="node_78055" labelType="html" label="MapPartitionsRDD [78055] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205702 { id="cluster_205702"; isCluster="true"; label="ObjectHashAggregate"; 78056 [id="node_78056" labelType="html" label="MapPartitionsRDD [78056] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205701 { id="cluster_205701"; isCluster="true"; label="Exchange"; 78057 [id="node_78057" labelType="html" label="MapPartitionsRDD [78057] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78041->78042; 78052->78053; 78042->78054; 78053->78054; 78054->78055; 78055->78056; 78056->78057; }

78040,78041

78051,78052

digraph G { id="graph_27783"; subgraph graph_stage_27783 { id="graph_stage_27783"; isCluster="true"; label="Stage 27783"; 78066 [id="node_78066" labelType="html" label="SQLExecutionRDD [78066] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_205701 { id="cluster_205701"; isCluster="true"; label="Exchange"; 78058 [id="node_78058" labelType="html" label="ShuffledRowRDD [78058] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205700 { id="cluster_205700"; isCluster="true"; label="ObjectHashAggregate"; 78059 [id="node_78059" labelType="html" label="MapPartitionsRDD [78059] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205699 { id="cluster_205699"; isCluster="true"; label="Project"; 78060 [id="node_78060" labelType="html" label="MapPartitionsRDD [78060] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205692 { id="cluster_205692"; isCluster="true"; label="WholeStageCodegen (16)"; 78061 [id="node_78061" labelType="html" label="MapPartitionsRDD [78061] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205691 { id="cluster_205691"; isCluster="true"; label="DeserializeToObject"; 78062 [id="node_78062" labelType="html" label="MapPartitionsRDD [78062] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205690 { id="cluster_205690"; isCluster="true"; label="MapPartitions"; 78063 [id="node_78063" labelType="html" label="MapPartitionsRDD [78063] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205623 { id="cluster_205623"; isCluster="true"; label="WholeStageCodegen (19)"; 78064 [id="node_78064" labelType="html" label="MapPartitionsRDD [78064] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205601 { id="cluster_205601"; isCluster="true"; label="DeserializeToObject"; 78065 [id="node_78065" labelType="html" label="MapPartitionsRDD [78065] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205778 { id="cluster_205778"; isCluster="true"; label="mapPartitions"; 78067 [id="node_78067" labelType="html" label="MapPartitionsRDD [78067] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205779 { id="cluster_205779"; isCluster="true"; label="mapPartitions"; 78068 [id="node_78068" labelType="html" label="MapPartitionsRDD [78068] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78058->78059; 78059->78060; 78060->78061; 78061->78062; 78062->78063; 78063->78064; 78064->78065; 78065->78066; 78066->78067; 78067->78068; }

78057,78058

78068

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
27783	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:46	1.0 s	30/30	49.4 KiB
27782	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:45	0.3 s	30/30	60.3 KiB	49.4 KiB
27781	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:45	0.2 s	30/30	234.9 KiB	46.5 KiB
27780	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:45	0.2 s	30/30	127.6 KiB	13.8 KiB
27779	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:45	0.4 s	37/37		127.6 KiB
27778	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 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.GeneratedMethodAccessor810.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 18:07:45	0.4 s	37/37		234.9 KiB

Page: