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

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

Enable zooming

digraph G { id="graph_446130"; subgraph graph_stage_446130 { id="graph_stage_446130"; isCluster="true"; label="Stage 446130"; subgraph cluster_3151132 { id="cluster_3151132"; isCluster="true"; label="Scan parquet "; 1242980 [id="node_1242980" labelType="html" label="FileScanRDD [1242980] start at FileStorageAdapterImpl.java:174}"]; 1242981 [id="node_1242981" labelType="html" label="MapPartitionsRDD [1242981] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151128 { id="cluster_3151128"; isCluster="true"; label="WholeStageCodegen (7)"; 1242982 [id="node_1242982" labelType="html" label="MapPartitionsRDD [1242982] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151127 { id="cluster_3151127"; isCluster="true"; label="Exchange"; 1242983 [id="node_1242983" labelType="html" label="MapPartitionsRDD [1242983] start at FileStorageAdapterImpl.java:174}"]; } } 1242980->1242981; 1242981->1242982; 1242982->1242983; }

digraph G { id="graph_446131"; subgraph graph_stage_446131 { id="graph_stage_446131"; isCluster="true"; label="Stage 446131"; subgraph cluster_3151099 { id="cluster_3151099"; isCluster="true"; label="Scan parquet "; 1242969 [id="node_1242969" labelType="html" label="FileScanRDD [1242969] start at FileStorageAdapterImpl.java:174}"]; 1242970 [id="node_1242970" labelType="html" label="MapPartitionsRDD [1242970] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151095 { id="cluster_3151095"; isCluster="true"; label="WholeStageCodegen (1)"; 1242971 [id="node_1242971" labelType="html" label="MapPartitionsRDD [1242971] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151094 { id="cluster_3151094"; isCluster="true"; label="Exchange"; 1242972 [id="node_1242972" labelType="html" label="MapPartitionsRDD [1242972] start at FileStorageAdapterImpl.java:174}"]; } } 1242969->1242970; 1242970->1242971; 1242971->1242972; }

digraph G { id="graph_446132"; subgraph graph_stage_446132 { id="graph_stage_446132"; isCluster="true"; label="Stage 446132"; subgraph cluster_3151094 { id="cluster_3151094"; isCluster="true"; label="Exchange"; 1242973 [id="node_1242973" labelType="html" label="ShuffledRowRDD [1242973] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151073 { id="cluster_3151073"; isCluster="true"; label="WholeStageCodegen (5)"; 1242974 [id="node_1242974" labelType="html" label="MapPartitionsRDD [1242974] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151072 { id="cluster_3151072"; isCluster="true"; label="Exchange"; 1242975 [id="node_1242975" labelType="html" label="MapPartitionsRDD [1242975] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242973->1242974; 1242974->1242975; }

1242972,1242973

digraph G { id="graph_446133"; subgraph graph_stage_446133 { id="graph_stage_446133"; isCluster="true"; label="Stage 446133"; subgraph cluster_3151127 { id="cluster_3151127"; isCluster="true"; label="Exchange"; 1242984 [id="node_1242984" labelType="html" label="ShuffledRowRDD [1242984] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151105 { id="cluster_3151105"; isCluster="true"; label="WholeStageCodegen (11)"; 1242985 [id="node_1242985" labelType="html" label="MapPartitionsRDD [1242985] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151104 { id="cluster_3151104"; isCluster="true"; label="Exchange"; 1242986 [id="node_1242986" labelType="html" label="MapPartitionsRDD [1242986] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242984->1242985; 1242985->1242986; }

1242983,1242984

digraph G { id="graph_446134"; subgraph graph_stage_446134 { id="graph_stage_446134"; isCluster="true"; label="Stage 446134"; subgraph cluster_3151072 { id="cluster_3151072"; isCluster="true"; label="Exchange"; 1242976 [id="node_1242976" labelType="html" label="ShuffledRowRDD [1242976] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151069 { id="cluster_3151069"; isCluster="true"; label="WholeStageCodegen (6)"; 1242977 [id="node_1242977" labelType="html" label="MapPartitionsRDD [1242977] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151104 { id="cluster_3151104"; isCluster="true"; label="Exchange"; 1242987 [id="node_1242987" labelType="html" label="ShuffledRowRDD [1242987] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151101 { id="cluster_3151101"; isCluster="true"; label="WholeStageCodegen (12)"; 1242988 [id="node_1242988" labelType="html" label="MapPartitionsRDD [1242988] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151065 { id="cluster_3151065"; isCluster="true"; label="WholeStageCodegen (13)"; 1242989 [id="node_1242989" labelType="html" label="ZippedPartitionsRDD2 [1242989] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242990 [id="node_1242990" labelType="html" label="MapPartitionsRDD [1242990] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151064 { id="cluster_3151064"; isCluster="true"; label="ObjectHashAggregate"; 1242991 [id="node_1242991" labelType="html" label="MapPartitionsRDD [1242991] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151063 { id="cluster_3151063"; isCluster="true"; label="Exchange"; 1242992 [id="node_1242992" labelType="html" label="MapPartitionsRDD [1242992] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242976->1242977; 1242987->1242988; 1242977->1242989; 1242988->1242989; 1242989->1242990; 1242990->1242991; 1242991->1242992; }

1242975,1242976

1242986,1242987

digraph G { id="graph_446135"; subgraph graph_stage_446135 { id="graph_stage_446135"; isCluster="true"; label="Stage 446135"; 1243001 [id="node_1243001" labelType="html" label="SQLExecutionRDD [1243001] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3151063 { id="cluster_3151063"; isCluster="true"; label="Exchange"; 1242993 [id="node_1242993" labelType="html" label="ShuffledRowRDD [1242993] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151062 { id="cluster_3151062"; isCluster="true"; label="ObjectHashAggregate"; 1242994 [id="node_1242994" labelType="html" label="MapPartitionsRDD [1242994] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151061 { id="cluster_3151061"; isCluster="true"; label="Project"; 1242995 [id="node_1242995" labelType="html" label="MapPartitionsRDD [1242995] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151054 { id="cluster_3151054"; isCluster="true"; label="WholeStageCodegen (16)"; 1242996 [id="node_1242996" labelType="html" label="MapPartitionsRDD [1242996] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151053 { id="cluster_3151053"; isCluster="true"; label="DeserializeToObject"; 1242997 [id="node_1242997" labelType="html" label="MapPartitionsRDD [1242997] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151052 { id="cluster_3151052"; isCluster="true"; label="MapPartitions"; 1242998 [id="node_1242998" labelType="html" label="MapPartitionsRDD [1242998] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150984 { id="cluster_3150984"; isCluster="true"; label="WholeStageCodegen (19)"; 1242999 [id="node_1242999" labelType="html" label="MapPartitionsRDD [1242999] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150963 { id="cluster_3150963"; isCluster="true"; label="DeserializeToObject"; 1243000 [id="node_1243000" labelType="html" label="MapPartitionsRDD [1243000] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151140 { id="cluster_3151140"; isCluster="true"; label="mapPartitions"; 1243002 [id="node_1243002" labelType="html" label="MapPartitionsRDD [1243002] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151141 { id="cluster_3151141"; isCluster="true"; label="mapPartitions"; 1243003 [id="node_1243003" labelType="html" label="MapPartitionsRDD [1243003] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242993->1242994; 1242994->1242995; 1242995->1242996; 1242996->1242997; 1242997->1242998; 1242998->1242999; 1242999->1243000; 1243000->1243001; 1243001->1243002; 1243002->1243003; }

1242992,1242993

1243003

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
446135	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:38	1 s	20/20	69.6 KiB
446134	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:37	0.3 s	20/20	87.5 KiB	69.6 KiB
446133	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:37	0.1 s	20/20	8.1 KiB	21.7 KiB
446132	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:37	0.1 s	20/20	13.5 KiB	65.8 KiB
446131	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:37	0.2 s	1/1		13.5 KiB
446130	tenants-pool-768	stream-10000001651-1 id = 470da58e-3bf0-43e9-92f9-208c55e721e2 runId = 6ced03eb-c046-4d38-8b3d-6156b8f3929b batch = 5 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:52:37	0.2 s	1/1		8.1 KiB

Page: