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

Status: SUCCEEDED
Submitted: 2026/08/10 09:29:56
Duration: 3 s
Associated SQL Query: 630
Job Group: cd2b79e8-7be4-4311-b6ba-b3d3f3439555
Completed Stages: 6

Enable zooming

digraph G { id="graph_3023"; subgraph graph_stage_3023 { id="graph_stage_3023"; isCluster="true"; label="Stage 3023"; subgraph cluster_20525 { id="cluster_20525"; isCluster="true"; label="Scan parquet "; 7676 [id="node_7676" labelType="html" label="FileScanRDD [7676] start at FileStorageAdapterImpl.java:177}"]; 7677 [id="node_7677" labelType="html" label="MapPartitionsRDD [7677] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20521 { id="cluster_20521"; isCluster="true"; label="WholeStageCodegen (1)"; 7678 [id="node_7678" labelType="html" label="MapPartitionsRDD [7678] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20520 { id="cluster_20520"; isCluster="true"; label="Exchange"; 7679 [id="node_7679" labelType="html" label="MapPartitionsRDD [7679] start at FileStorageAdapterImpl.java:177}"]; } } 7676->7677; 7677->7678; 7678->7679; }

digraph G { id="graph_3024"; subgraph graph_stage_3024 { id="graph_stage_3024"; isCluster="true"; label="Stage 3024"; subgraph cluster_20551 { id="cluster_20551"; isCluster="true"; label="Scan parquet "; 7687 [id="node_7687" labelType="html" label="FileScanRDD [7687] start at FileStorageAdapterImpl.java:177}"]; 7688 [id="node_7688" labelType="html" label="MapPartitionsRDD [7688] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20547 { id="cluster_20547"; isCluster="true"; label="WholeStageCodegen (7)"; 7689 [id="node_7689" labelType="html" label="MapPartitionsRDD [7689] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20546 { id="cluster_20546"; isCluster="true"; label="Exchange"; 7690 [id="node_7690" labelType="html" label="MapPartitionsRDD [7690] start at FileStorageAdapterImpl.java:177}"]; } } 7687->7688; 7688->7689; 7689->7690; }

digraph G { id="graph_3025"; subgraph graph_stage_3025 { id="graph_stage_3025"; isCluster="true"; label="Stage 3025"; subgraph cluster_20546 { id="cluster_20546"; isCluster="true"; label="Exchange"; 7691 [id="node_7691" labelType="html" label="ShuffledRowRDD [7691] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20531 { id="cluster_20531"; isCluster="true"; label="WholeStageCodegen (11)"; 7692 [id="node_7692" labelType="html" label="MapPartitionsRDD [7692] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20530 { id="cluster_20530"; isCluster="true"; label="Exchange"; 7693 [id="node_7693" labelType="html" label="MapPartitionsRDD [7693] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7691->7692; 7692->7693; }

7690,7691

digraph G { id="graph_3026"; subgraph graph_stage_3026 { id="graph_stage_3026"; isCluster="true"; label="Stage 3026"; subgraph cluster_20520 { id="cluster_20520"; isCluster="true"; label="Exchange"; 7680 [id="node_7680" labelType="html" label="ShuffledRowRDD [7680] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20492 { id="cluster_20492"; isCluster="true"; label="WholeStageCodegen (5)"; 7681 [id="node_7681" labelType="html" label="MapPartitionsRDD [7681] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20491 { id="cluster_20491"; isCluster="true"; label="Exchange"; 7682 [id="node_7682" labelType="html" label="MapPartitionsRDD [7682] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7680->7681; 7681->7682; }

7679,7680

digraph G { id="graph_3027"; subgraph graph_stage_3027 { id="graph_stage_3027"; isCluster="true"; label="Stage 3027"; subgraph cluster_20491 { id="cluster_20491"; isCluster="true"; label="Exchange"; 7683 [id="node_7683" labelType="html" label="ShuffledRowRDD [7683] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20488 { id="cluster_20488"; isCluster="true"; label="WholeStageCodegen (6)"; 7684 [id="node_7684" labelType="html" label="MapPartitionsRDD [7684] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20530 { id="cluster_20530"; isCluster="true"; label="Exchange"; 7694 [id="node_7694" labelType="html" label="ShuffledRowRDD [7694] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20527 { id="cluster_20527"; isCluster="true"; label="WholeStageCodegen (12)"; 7695 [id="node_7695" labelType="html" label="MapPartitionsRDD [7695] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20484 { id="cluster_20484"; isCluster="true"; label="WholeStageCodegen (13)"; 7696 [id="node_7696" labelType="html" label="ZippedPartitionsRDD2 [7696] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 7697 [id="node_7697" labelType="html" label="MapPartitionsRDD [7697] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20483 { id="cluster_20483"; isCluster="true"; label="ObjectHashAggregate"; 7698 [id="node_7698" labelType="html" label="MapPartitionsRDD [7698] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20482 { id="cluster_20482"; isCluster="true"; label="Exchange"; 7699 [id="node_7699" labelType="html" label="MapPartitionsRDD [7699] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7683->7684; 7694->7695; 7684->7696; 7695->7696; 7696->7697; 7697->7698; 7698->7699; }

7682,7683

7693,7694

digraph G { id="graph_3028"; subgraph graph_stage_3028 { id="graph_stage_3028"; isCluster="true"; label="Stage 3028"; 7708 [id="node_7708" labelType="html" label="SQLExecutionRDD [7708] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_20482 { id="cluster_20482"; isCluster="true"; label="Exchange"; 7700 [id="node_7700" labelType="html" label="ShuffledRowRDD [7700] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20481 { id="cluster_20481"; isCluster="true"; label="ObjectHashAggregate"; 7701 [id="node_7701" labelType="html" label="MapPartitionsRDD [7701] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20480 { id="cluster_20480"; isCluster="true"; label="Project"; 7702 [id="node_7702" labelType="html" label="MapPartitionsRDD [7702] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20473 { id="cluster_20473"; isCluster="true"; label="WholeStageCodegen (16)"; 7703 [id="node_7703" labelType="html" label="MapPartitionsRDD [7703] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20472 { id="cluster_20472"; isCluster="true"; label="DeserializeToObject"; 7704 [id="node_7704" labelType="html" label="MapPartitionsRDD [7704] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20471 { id="cluster_20471"; isCluster="true"; label="MapPartitions"; 7705 [id="node_7705" labelType="html" label="MapPartitionsRDD [7705] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20401 { id="cluster_20401"; isCluster="true"; label="WholeStageCodegen (19)"; 7706 [id="node_7706" labelType="html" label="MapPartitionsRDD [7706] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20382 { id="cluster_20382"; isCluster="true"; label="DeserializeToObject"; 7707 [id="node_7707" labelType="html" label="MapPartitionsRDD [7707] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20559 { id="cluster_20559"; isCluster="true"; label="mapPartitions"; 7709 [id="node_7709" labelType="html" label="MapPartitionsRDD [7709] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_20560 { id="cluster_20560"; isCluster="true"; label="mapPartitions"; 7710 [id="node_7710" labelType="html" label="MapPartitionsRDD [7710] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 7700->7701; 7701->7702; 7702->7703; 7703->7704; 7704->7705; 7705->7706; 7706->7707; 7707->7708; 7708->7709; 7709->7710; }

7699,7700

7710

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3028	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:57	2 s	20/20	202.9 KiB
3027	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:57	0.5 s	20/20	258.7 KiB	202.9 KiB
3026	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:57	0.2 s	20/20	22.9 KiB	196.7 KiB
3025	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:57	0.2 s	20/20	15.6 KiB	62.0 KiB
3024	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:56	0.2 s	1/1		15.6 KiB
3023	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:29:56	0.2 s	1/1		22.9 KiB

Page: