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

Status: SUCCEEDED
Submitted: 2026/08/10 09:39:25
Duration: 2 s
Associated SQL Query: 773
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 6

Enable zooming

digraph G { id="graph_3710"; subgraph graph_stage_3710 { id="graph_stage_3710"; isCluster="true"; label="Stage 3710"; subgraph cluster_25659 { id="cluster_25659"; isCluster="true"; label="Scan parquet "; 9443 [id="node_9443" labelType="html" label="FileScanRDD [9443] start at FileStorageAdapterImpl.java:177}"]; 9444 [id="node_9444" labelType="html" label="MapPartitionsRDD [9444] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25655 { id="cluster_25655"; isCluster="true"; label="WholeStageCodegen (1)"; 9445 [id="node_9445" labelType="html" label="MapPartitionsRDD [9445] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25654 { id="cluster_25654"; isCluster="true"; label="Exchange"; 9446 [id="node_9446" labelType="html" label="MapPartitionsRDD [9446] start at FileStorageAdapterImpl.java:177}"]; } } 9443->9444; 9444->9445; 9445->9446; }

digraph G { id="graph_3711"; subgraph graph_stage_3711 { id="graph_stage_3711"; isCluster="true"; label="Stage 3711"; subgraph cluster_25685 { id="cluster_25685"; isCluster="true"; label="Scan parquet "; 9454 [id="node_9454" labelType="html" label="FileScanRDD [9454] start at FileStorageAdapterImpl.java:177}"]; 9455 [id="node_9455" labelType="html" label="MapPartitionsRDD [9455] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25681 { id="cluster_25681"; isCluster="true"; label="WholeStageCodegen (7)"; 9456 [id="node_9456" labelType="html" label="MapPartitionsRDD [9456] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25680 { id="cluster_25680"; isCluster="true"; label="Exchange"; 9457 [id="node_9457" labelType="html" label="MapPartitionsRDD [9457] start at FileStorageAdapterImpl.java:177}"]; } } 9454->9455; 9455->9456; 9456->9457; }

digraph G { id="graph_3712"; subgraph graph_stage_3712 { id="graph_stage_3712"; isCluster="true"; label="Stage 3712"; subgraph cluster_25680 { id="cluster_25680"; isCluster="true"; label="Exchange"; 9458 [id="node_9458" labelType="html" label="ShuffledRowRDD [9458] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25665 { id="cluster_25665"; isCluster="true"; label="WholeStageCodegen (11)"; 9459 [id="node_9459" labelType="html" label="MapPartitionsRDD [9459] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25664 { id="cluster_25664"; isCluster="true"; label="Exchange"; 9460 [id="node_9460" labelType="html" label="MapPartitionsRDD [9460] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9458->9459; 9459->9460; }

9457,9458

digraph G { id="graph_3713"; subgraph graph_stage_3713 { id="graph_stage_3713"; isCluster="true"; label="Stage 3713"; subgraph cluster_25654 { id="cluster_25654"; isCluster="true"; label="Exchange"; 9447 [id="node_9447" labelType="html" label="ShuffledRowRDD [9447] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25626 { id="cluster_25626"; isCluster="true"; label="WholeStageCodegen (5)"; 9448 [id="node_9448" labelType="html" label="MapPartitionsRDD [9448] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25625 { id="cluster_25625"; isCluster="true"; label="Exchange"; 9449 [id="node_9449" labelType="html" label="MapPartitionsRDD [9449] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9447->9448; 9448->9449; }

9446,9447

digraph G { id="graph_3714"; subgraph graph_stage_3714 { id="graph_stage_3714"; isCluster="true"; label="Stage 3714"; subgraph cluster_25625 { id="cluster_25625"; isCluster="true"; label="Exchange"; 9450 [id="node_9450" labelType="html" label="ShuffledRowRDD [9450] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25622 { id="cluster_25622"; isCluster="true"; label="WholeStageCodegen (6)"; 9451 [id="node_9451" labelType="html" label="MapPartitionsRDD [9451] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25664 { id="cluster_25664"; isCluster="true"; label="Exchange"; 9461 [id="node_9461" labelType="html" label="ShuffledRowRDD [9461] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25661 { id="cluster_25661"; isCluster="true"; label="WholeStageCodegen (12)"; 9462 [id="node_9462" labelType="html" label="MapPartitionsRDD [9462] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25618 { id="cluster_25618"; isCluster="true"; label="WholeStageCodegen (13)"; 9463 [id="node_9463" labelType="html" label="ZippedPartitionsRDD2 [9463] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 9464 [id="node_9464" labelType="html" label="MapPartitionsRDD [9464] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25617 { id="cluster_25617"; isCluster="true"; label="ObjectHashAggregate"; 9465 [id="node_9465" labelType="html" label="MapPartitionsRDD [9465] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25616 { id="cluster_25616"; isCluster="true"; label="Exchange"; 9466 [id="node_9466" labelType="html" label="MapPartitionsRDD [9466] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9450->9451; 9461->9462; 9451->9463; 9462->9463; 9463->9464; 9464->9465; 9465->9466; }

9449,9450

9460,9461

digraph G { id="graph_3715"; subgraph graph_stage_3715 { id="graph_stage_3715"; isCluster="true"; label="Stage 3715"; 9475 [id="node_9475" labelType="html" label="SQLExecutionRDD [9475] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_25616 { id="cluster_25616"; isCluster="true"; label="Exchange"; 9467 [id="node_9467" labelType="html" label="ShuffledRowRDD [9467] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25615 { id="cluster_25615"; isCluster="true"; label="ObjectHashAggregate"; 9468 [id="node_9468" labelType="html" label="MapPartitionsRDD [9468] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25614 { id="cluster_25614"; isCluster="true"; label="Project"; 9469 [id="node_9469" labelType="html" label="MapPartitionsRDD [9469] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25607 { id="cluster_25607"; isCluster="true"; label="WholeStageCodegen (16)"; 9470 [id="node_9470" labelType="html" label="MapPartitionsRDD [9470] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25606 { id="cluster_25606"; isCluster="true"; label="DeserializeToObject"; 9471 [id="node_9471" labelType="html" label="MapPartitionsRDD [9471] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25605 { id="cluster_25605"; isCluster="true"; label="MapPartitions"; 9472 [id="node_9472" labelType="html" label="MapPartitionsRDD [9472] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25537 { id="cluster_25537"; isCluster="true"; label="WholeStageCodegen (19)"; 9473 [id="node_9473" labelType="html" label="MapPartitionsRDD [9473] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25516 { id="cluster_25516"; isCluster="true"; label="DeserializeToObject"; 9474 [id="node_9474" labelType="html" label="MapPartitionsRDD [9474] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25693 { id="cluster_25693"; isCluster="true"; label="mapPartitions"; 9476 [id="node_9476" labelType="html" label="MapPartitionsRDD [9476] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_25694 { id="cluster_25694"; isCluster="true"; label="mapPartitions"; 9477 [id="node_9477" labelType="html" label="MapPartitionsRDD [9477] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 9467->9468; 9468->9469; 9469->9470; 9470->9471; 9471->9472; 9472->9473; 9473->9474; 9474->9475; 9475->9476; 9476->9477; }

9466,9467

9477

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3715	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:26	2 s	20/20	499.1 KiB
3714	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:25	0.4 s	20/20	689.2 KiB	499.1 KiB
3713	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:25	0.1 s	20/20	79.5 KiB	496.4 KiB
3712	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:25	0.1 s	20/20	43.6 KiB	192.8 KiB
3711	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:25	0.2 s	1/1		43.6 KiB
3710	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 3 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:39:25	0.2 s	1/1		79.5 KiB

Page: