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

Status: SUCCEEDED
Submitted: 2026/07/21 20:54:31
Duration: 3 s
Associated SQL Query: 38581
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 6

Enable zooming

digraph G { id="graph_172506"; subgraph graph_stage_172506 { id="graph_stage_172506"; isCluster="true"; label="Stage 172506"; subgraph cluster_1238527 { id="cluster_1238527"; isCluster="true"; label="Scan parquet "; 481697 [id="node_481697" labelType="html" label="FileScanRDD [481697] start at FileStorageAdapterImpl.java:179}"]; 481698 [id="node_481698" labelType="html" label="MapPartitionsRDD [481698] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238523 { id="cluster_1238523"; isCluster="true"; label="WholeStageCodegen (1)"; 481699 [id="node_481699" labelType="html" label="MapPartitionsRDD [481699] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238522 { id="cluster_1238522"; isCluster="true"; label="Exchange"; 481700 [id="node_481700" labelType="html" label="MapPartitionsRDD [481700] start at FileStorageAdapterImpl.java:179}"]; } } 481697->481698; 481698->481699; 481699->481700; }

digraph G { id="graph_172507"; subgraph graph_stage_172507 { id="graph_stage_172507"; isCluster="true"; label="Stage 172507"; subgraph cluster_1238553 { id="cluster_1238553"; isCluster="true"; label="Scan parquet "; 481708 [id="node_481708" labelType="html" label="FileScanRDD [481708] start at FileStorageAdapterImpl.java:179}"]; 481709 [id="node_481709" labelType="html" label="MapPartitionsRDD [481709] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238549 { id="cluster_1238549"; isCluster="true"; label="WholeStageCodegen (7)"; 481710 [id="node_481710" labelType="html" label="MapPartitionsRDD [481710] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238548 { id="cluster_1238548"; isCluster="true"; label="Exchange"; 481711 [id="node_481711" labelType="html" label="MapPartitionsRDD [481711] start at FileStorageAdapterImpl.java:179}"]; } } 481708->481709; 481709->481710; 481710->481711; }

digraph G { id="graph_172508"; subgraph graph_stage_172508 { id="graph_stage_172508"; isCluster="true"; label="Stage 172508"; subgraph cluster_1238548 { id="cluster_1238548"; isCluster="true"; label="Exchange"; 481712 [id="node_481712" labelType="html" label="ShuffledRowRDD [481712] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238533 { id="cluster_1238533"; isCluster="true"; label="WholeStageCodegen (11)"; 481713 [id="node_481713" labelType="html" label="MapPartitionsRDD [481713] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238532 { id="cluster_1238532"; isCluster="true"; label="Exchange"; 481714 [id="node_481714" labelType="html" label="MapPartitionsRDD [481714] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481712->481713; 481713->481714; }

481711,481712

digraph G { id="graph_172509"; subgraph graph_stage_172509 { id="graph_stage_172509"; isCluster="true"; label="Stage 172509"; subgraph cluster_1238522 { id="cluster_1238522"; isCluster="true"; label="Exchange"; 481701 [id="node_481701" labelType="html" label="ShuffledRowRDD [481701] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238494 { id="cluster_1238494"; isCluster="true"; label="WholeStageCodegen (5)"; 481702 [id="node_481702" labelType="html" label="MapPartitionsRDD [481702] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238493 { id="cluster_1238493"; isCluster="true"; label="Exchange"; 481703 [id="node_481703" labelType="html" label="MapPartitionsRDD [481703] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481701->481702; 481702->481703; }

481700,481701

digraph G { id="graph_172510"; subgraph graph_stage_172510 { id="graph_stage_172510"; isCluster="true"; label="Stage 172510"; subgraph cluster_1238493 { id="cluster_1238493"; isCluster="true"; label="Exchange"; 481704 [id="node_481704" labelType="html" label="ShuffledRowRDD [481704] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238490 { id="cluster_1238490"; isCluster="true"; label="WholeStageCodegen (6)"; 481705 [id="node_481705" labelType="html" label="MapPartitionsRDD [481705] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238532 { id="cluster_1238532"; isCluster="true"; label="Exchange"; 481715 [id="node_481715" labelType="html" label="ShuffledRowRDD [481715] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238529 { id="cluster_1238529"; isCluster="true"; label="WholeStageCodegen (12)"; 481716 [id="node_481716" labelType="html" label="MapPartitionsRDD [481716] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238486 { id="cluster_1238486"; isCluster="true"; label="WholeStageCodegen (13)"; 481717 [id="node_481717" labelType="html" label="ZippedPartitionsRDD2 [481717] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 481718 [id="node_481718" labelType="html" label="MapPartitionsRDD [481718] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238485 { id="cluster_1238485"; isCluster="true"; label="ObjectHashAggregate"; 481719 [id="node_481719" labelType="html" label="MapPartitionsRDD [481719] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238484 { id="cluster_1238484"; isCluster="true"; label="Exchange"; 481720 [id="node_481720" labelType="html" label="MapPartitionsRDD [481720] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481704->481705; 481715->481716; 481705->481717; 481716->481717; 481717->481718; 481718->481719; 481719->481720; }

481703,481704

481714,481715

digraph G { id="graph_172511"; subgraph graph_stage_172511 { id="graph_stage_172511"; isCluster="true"; label="Stage 172511"; 481729 [id="node_481729" labelType="html" label="SQLExecutionRDD [481729] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1238484 { id="cluster_1238484"; isCluster="true"; label="Exchange"; 481721 [id="node_481721" labelType="html" label="ShuffledRowRDD [481721] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238483 { id="cluster_1238483"; isCluster="true"; label="ObjectHashAggregate"; 481722 [id="node_481722" labelType="html" label="MapPartitionsRDD [481722] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238482 { id="cluster_1238482"; isCluster="true"; label="Project"; 481723 [id="node_481723" labelType="html" label="MapPartitionsRDD [481723] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238461 { id="cluster_1238461"; isCluster="true"; label="WholeStageCodegen (16)"; 481724 [id="node_481724" labelType="html" label="MapPartitionsRDD [481724] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238460 { id="cluster_1238460"; isCluster="true"; label="DeserializeToObject"; 481725 [id="node_481725" labelType="html" label="MapPartitionsRDD [481725] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238459 { id="cluster_1238459"; isCluster="true"; label="MapPartitions"; 481726 [id="node_481726" labelType="html" label="MapPartitionsRDD [481726] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238405 { id="cluster_1238405"; isCluster="true"; label="WholeStageCodegen (19)"; 481727 [id="node_481727" labelType="html" label="MapPartitionsRDD [481727] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238384 { id="cluster_1238384"; isCluster="true"; label="DeserializeToObject"; 481728 [id="node_481728" labelType="html" label="MapPartitionsRDD [481728] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238561 { id="cluster_1238561"; isCluster="true"; label="mapPartitions"; 481730 [id="node_481730" labelType="html" label="MapPartitionsRDD [481730] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238562 { id="cluster_1238562"; isCluster="true"; label="mapPartitions"; 481731 [id="node_481731" labelType="html" label="MapPartitionsRDD [481731] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 481721->481722; 481722->481723; 481723->481724; 481724->481725; 481725->481726; 481726->481727; 481727->481728; 481728->481729; 481729->481730; 481730->481731; }

481720,481721

481731

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
172511	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:32	2 s	30/30	92.8 KiB
172510	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:32	0.7 s	30/30	226.0 KiB	92.8 KiB
172509	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:31	0.1 s	30/30	1988.9 KiB	221.1 KiB
172508	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:31	0.4 s	30/30	152.9 KiB	4.8 KiB
172507	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:31	0.4 s	26/26		152.9 KiB
172506	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 92 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/07/21 20:54:31	0.5 s	26/26		1988.9 KiB

Page: