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

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

Enable zooming

digraph G { id="graph_318769"; subgraph graph_stage_318769 { id="graph_stage_318769"; isCluster="true"; label="Stage 318769"; subgraph cluster_2311866 { id="cluster_2311866"; isCluster="true"; label="Scan parquet "; 891987 [id="node_891987" labelType="html" label="FileScanRDD [891987] start at FileStorageAdapterImpl.java:174}"]; 891988 [id="node_891988" labelType="html" label="MapPartitionsRDD [891988] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311862 { id="cluster_2311862"; isCluster="true"; label="WholeStageCodegen (7)"; 891989 [id="node_891989" labelType="html" label="MapPartitionsRDD [891989] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311861 { id="cluster_2311861"; isCluster="true"; label="Exchange"; 891990 [id="node_891990" labelType="html" label="MapPartitionsRDD [891990] start at FileStorageAdapterImpl.java:174}"]; } } 891987->891988; 891988->891989; 891989->891990; }

digraph G { id="graph_318770"; subgraph graph_stage_318770 { id="graph_stage_318770"; isCluster="true"; label="Stage 318770"; subgraph cluster_2311840 { id="cluster_2311840"; isCluster="true"; label="Scan parquet "; 891976 [id="node_891976" labelType="html" label="FileScanRDD [891976] start at FileStorageAdapterImpl.java:174}"]; 891977 [id="node_891977" labelType="html" label="MapPartitionsRDD [891977] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311836 { id="cluster_2311836"; isCluster="true"; label="WholeStageCodegen (1)"; 891978 [id="node_891978" labelType="html" label="MapPartitionsRDD [891978] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311835 { id="cluster_2311835"; isCluster="true"; label="Exchange"; 891979 [id="node_891979" labelType="html" label="MapPartitionsRDD [891979] start at FileStorageAdapterImpl.java:174}"]; } } 891976->891977; 891977->891978; 891978->891979; }

digraph G { id="graph_318771"; subgraph graph_stage_318771 { id="graph_stage_318771"; isCluster="true"; label="Stage 318771"; subgraph cluster_2311835 { id="cluster_2311835"; isCluster="true"; label="Exchange"; 891980 [id="node_891980" labelType="html" label="ShuffledRowRDD [891980] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311814 { id="cluster_2311814"; isCluster="true"; label="WholeStageCodegen (5)"; 891981 [id="node_891981" labelType="html" label="MapPartitionsRDD [891981] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311813 { id="cluster_2311813"; isCluster="true"; label="Exchange"; 891982 [id="node_891982" labelType="html" label="MapPartitionsRDD [891982] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891980->891981; 891981->891982; }

891979,891980

digraph G { id="graph_318772"; subgraph graph_stage_318772 { id="graph_stage_318772"; isCluster="true"; label="Stage 318772"; subgraph cluster_2311861 { id="cluster_2311861"; isCluster="true"; label="Exchange"; 891991 [id="node_891991" labelType="html" label="ShuffledRowRDD [891991] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311846 { id="cluster_2311846"; isCluster="true"; label="WholeStageCodegen (11)"; 891992 [id="node_891992" labelType="html" label="MapPartitionsRDD [891992] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311845 { id="cluster_2311845"; isCluster="true"; label="Exchange"; 891993 [id="node_891993" labelType="html" label="MapPartitionsRDD [891993] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891991->891992; 891992->891993; }

891990,891991

digraph G { id="graph_318773"; subgraph graph_stage_318773 { id="graph_stage_318773"; isCluster="true"; label="Stage 318773"; subgraph cluster_2311813 { id="cluster_2311813"; isCluster="true"; label="Exchange"; 891983 [id="node_891983" labelType="html" label="ShuffledRowRDD [891983] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311810 { id="cluster_2311810"; isCluster="true"; label="WholeStageCodegen (6)"; 891984 [id="node_891984" labelType="html" label="MapPartitionsRDD [891984] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311845 { id="cluster_2311845"; isCluster="true"; label="Exchange"; 891994 [id="node_891994" labelType="html" label="ShuffledRowRDD [891994] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311842 { id="cluster_2311842"; isCluster="true"; label="WholeStageCodegen (12)"; 891995 [id="node_891995" labelType="html" label="MapPartitionsRDD [891995] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311806 { id="cluster_2311806"; isCluster="true"; label="WholeStageCodegen (13)"; 891996 [id="node_891996" labelType="html" label="ZippedPartitionsRDD2 [891996] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 891997 [id="node_891997" labelType="html" label="MapPartitionsRDD [891997] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311805 { id="cluster_2311805"; isCluster="true"; label="ObjectHashAggregate"; 891998 [id="node_891998" labelType="html" label="MapPartitionsRDD [891998] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311804 { id="cluster_2311804"; isCluster="true"; label="Exchange"; 891999 [id="node_891999" labelType="html" label="MapPartitionsRDD [891999] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891983->891984; 891994->891995; 891984->891996; 891995->891996; 891996->891997; 891997->891998; 891998->891999; }

891982,891983

891993,891994

digraph G { id="graph_318774"; subgraph graph_stage_318774 { id="graph_stage_318774"; isCluster="true"; label="Stage 318774"; 892008 [id="node_892008" labelType="html" label="SQLExecutionRDD [892008] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2311804 { id="cluster_2311804"; isCluster="true"; label="Exchange"; 892000 [id="node_892000" labelType="html" label="ShuffledRowRDD [892000] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311803 { id="cluster_2311803"; isCluster="true"; label="ObjectHashAggregate"; 892001 [id="node_892001" labelType="html" label="MapPartitionsRDD [892001] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311802 { id="cluster_2311802"; isCluster="true"; label="Project"; 892002 [id="node_892002" labelType="html" label="MapPartitionsRDD [892002] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311774 { id="cluster_2311774"; isCluster="true"; label="WholeStageCodegen (16)"; 892003 [id="node_892003" labelType="html" label="MapPartitionsRDD [892003] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311773 { id="cluster_2311773"; isCluster="true"; label="DeserializeToObject"; 892004 [id="node_892004" labelType="html" label="MapPartitionsRDD [892004] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311772 { id="cluster_2311772"; isCluster="true"; label="MapPartitions"; 892005 [id="node_892005" labelType="html" label="MapPartitionsRDD [892005] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311718 { id="cluster_2311718"; isCluster="true"; label="WholeStageCodegen (19)"; 892006 [id="node_892006" labelType="html" label="MapPartitionsRDD [892006] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311697 { id="cluster_2311697"; isCluster="true"; label="DeserializeToObject"; 892007 [id="node_892007" labelType="html" label="MapPartitionsRDD [892007] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311874 { id="cluster_2311874"; isCluster="true"; label="mapPartitions"; 892009 [id="node_892009" labelType="html" label="MapPartitionsRDD [892009] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2311875 { id="cluster_2311875"; isCluster="true"; label="mapPartitions"; 892010 [id="node_892010" labelType="html" label="MapPartitionsRDD [892010] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 892000->892001; 892001->892002; 892002->892003; 892003->892004; 892004->892005; 892005->892006; 892006->892007; 892007->892008; 892008->892009; 892009->892010; }

891999,892000

892010

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
318774	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:58	1 s	30/30	13.3 KiB
318773	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:57	1 s	30/30	28.4 KiB	13.3 KiB
318772	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:56	0.6 s	30/30	2.3 KiB	3.1 KiB
318771	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:56	0.2 s	30/30	5.3 KiB	25.4 KiB
318770	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:56	0.4 s	1/1		5.3 KiB
318769	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 31 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:49:56	0.3 s	1/1		2.3 KiB

Page: