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

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

Enable zooming

digraph G { id="graph_319073"; subgraph graph_stage_319073 { id="graph_stage_319073"; isCluster="true"; label="Stage 319073"; subgraph cluster_2314033 { id="cluster_2314033"; isCluster="true"; label="Scan parquet "; 892872 [id="node_892872" labelType="html" label="FileScanRDD [892872] start at FileStorageAdapterImpl.java:174}"]; 892873 [id="node_892873" labelType="html" label="MapPartitionsRDD [892873] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314029 { id="cluster_2314029"; isCluster="true"; label="WholeStageCodegen (7)"; 892874 [id="node_892874" labelType="html" label="MapPartitionsRDD [892874] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314028 { id="cluster_2314028"; isCluster="true"; label="Exchange"; 892875 [id="node_892875" labelType="html" label="MapPartitionsRDD [892875] start at FileStorageAdapterImpl.java:174}"]; } } 892872->892873; 892873->892874; 892874->892875; }

digraph G { id="graph_319074"; subgraph graph_stage_319074 { id="graph_stage_319074"; isCluster="true"; label="Stage 319074"; subgraph cluster_2314007 { id="cluster_2314007"; isCluster="true"; label="Scan parquet "; 892861 [id="node_892861" labelType="html" label="FileScanRDD [892861] start at FileStorageAdapterImpl.java:174}"]; 892862 [id="node_892862" labelType="html" label="MapPartitionsRDD [892862] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314003 { id="cluster_2314003"; isCluster="true"; label="WholeStageCodegen (1)"; 892863 [id="node_892863" labelType="html" label="MapPartitionsRDD [892863] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314002 { id="cluster_2314002"; isCluster="true"; label="Exchange"; 892864 [id="node_892864" labelType="html" label="MapPartitionsRDD [892864] start at FileStorageAdapterImpl.java:174}"]; } } 892861->892862; 892862->892863; 892863->892864; }

digraph G { id="graph_319075"; subgraph graph_stage_319075 { id="graph_stage_319075"; isCluster="true"; label="Stage 319075"; subgraph cluster_2314002 { id="cluster_2314002"; isCluster="true"; label="Exchange"; 892865 [id="node_892865" labelType="html" label="ShuffledRowRDD [892865] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313981 { id="cluster_2313981"; isCluster="true"; label="WholeStageCodegen (5)"; 892866 [id="node_892866" labelType="html" label="MapPartitionsRDD [892866] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313980 { id="cluster_2313980"; isCluster="true"; label="Exchange"; 892867 [id="node_892867" labelType="html" label="MapPartitionsRDD [892867] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 892865->892866; 892866->892867; }

892864,892865

digraph G { id="graph_319076"; subgraph graph_stage_319076 { id="graph_stage_319076"; isCluster="true"; label="Stage 319076"; subgraph cluster_2314028 { id="cluster_2314028"; isCluster="true"; label="Exchange"; 892876 [id="node_892876" labelType="html" label="ShuffledRowRDD [892876] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314013 { id="cluster_2314013"; isCluster="true"; label="WholeStageCodegen (11)"; 892877 [id="node_892877" labelType="html" label="MapPartitionsRDD [892877] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314012 { id="cluster_2314012"; isCluster="true"; label="Exchange"; 892878 [id="node_892878" labelType="html" label="MapPartitionsRDD [892878] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 892876->892877; 892877->892878; }

892875,892876

digraph G { id="graph_319077"; subgraph graph_stage_319077 { id="graph_stage_319077"; isCluster="true"; label="Stage 319077"; subgraph cluster_2313980 { id="cluster_2313980"; isCluster="true"; label="Exchange"; 892868 [id="node_892868" labelType="html" label="ShuffledRowRDD [892868] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313977 { id="cluster_2313977"; isCluster="true"; label="WholeStageCodegen (6)"; 892869 [id="node_892869" labelType="html" label="MapPartitionsRDD [892869] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314012 { id="cluster_2314012"; isCluster="true"; label="Exchange"; 892879 [id="node_892879" labelType="html" label="ShuffledRowRDD [892879] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314009 { id="cluster_2314009"; isCluster="true"; label="WholeStageCodegen (12)"; 892880 [id="node_892880" labelType="html" label="MapPartitionsRDD [892880] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313973 { id="cluster_2313973"; isCluster="true"; label="WholeStageCodegen (13)"; 892881 [id="node_892881" labelType="html" label="ZippedPartitionsRDD2 [892881] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 892882 [id="node_892882" labelType="html" label="MapPartitionsRDD [892882] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313972 { id="cluster_2313972"; isCluster="true"; label="ObjectHashAggregate"; 892883 [id="node_892883" labelType="html" label="MapPartitionsRDD [892883] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313971 { id="cluster_2313971"; isCluster="true"; label="Exchange"; 892884 [id="node_892884" labelType="html" label="MapPartitionsRDD [892884] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 892868->892869; 892879->892880; 892869->892881; 892880->892881; 892881->892882; 892882->892883; 892883->892884; }

892867,892868

892878,892879

digraph G { id="graph_319078"; subgraph graph_stage_319078 { id="graph_stage_319078"; isCluster="true"; label="Stage 319078"; 892893 [id="node_892893" labelType="html" label="SQLExecutionRDD [892893] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2313971 { id="cluster_2313971"; isCluster="true"; label="Exchange"; 892885 [id="node_892885" labelType="html" label="ShuffledRowRDD [892885] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313970 { id="cluster_2313970"; isCluster="true"; label="ObjectHashAggregate"; 892886 [id="node_892886" labelType="html" label="MapPartitionsRDD [892886] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313969 { id="cluster_2313969"; isCluster="true"; label="Project"; 892887 [id="node_892887" labelType="html" label="MapPartitionsRDD [892887] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313962 { id="cluster_2313962"; isCluster="true"; label="WholeStageCodegen (16)"; 892888 [id="node_892888" labelType="html" label="MapPartitionsRDD [892888] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313961 { id="cluster_2313961"; isCluster="true"; label="DeserializeToObject"; 892889 [id="node_892889" labelType="html" label="MapPartitionsRDD [892889] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313960 { id="cluster_2313960"; isCluster="true"; label="MapPartitions"; 892890 [id="node_892890" labelType="html" label="MapPartitionsRDD [892890] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313890 { id="cluster_2313890"; isCluster="true"; label="WholeStageCodegen (19)"; 892891 [id="node_892891" labelType="html" label="MapPartitionsRDD [892891] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2313864 { id="cluster_2313864"; isCluster="true"; label="DeserializeToObject"; 892892 [id="node_892892" labelType="html" label="MapPartitionsRDD [892892] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314041 { id="cluster_2314041"; isCluster="true"; label="mapPartitions"; 892894 [id="node_892894" labelType="html" label="MapPartitionsRDD [892894] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314042 { id="cluster_2314042"; isCluster="true"; label="mapPartitions"; 892895 [id="node_892895" labelType="html" label="MapPartitionsRDD [892895] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 892885->892886; 892886->892887; 892887->892888; 892888->892889; 892889->892890; 892890->892891; 892891->892892; 892892->892893; 892893->892894; 892894->892895; }

892884,892885

892895

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
319078	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:42	1 s	30/30	13.3 KiB
319077	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:41	0.9 s	30/30	16.9 KiB	13.3 KiB
319076	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:41	0.5 s	30/30	2.3 KiB	3.1 KiB
319075	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:41	0.2 s	30/30	5.3 KiB	13.9 KiB
319074	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:40	0.3 s	1/1		5.3 KiB
319073	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 35 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:52:40	0.4 s	1/1		2.3 KiB

Page: