crp-order-quantity-kpi-service

Status: SUCCEEDED
Submitted: 2026/04/10 15:02:11
Duration: 3 s
Associated SQL Query: 4
Job Group: b7dd4133-4fdf-3440-8f6d-09069cda4413
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_7"; subgraph graph_stage_7 { id="graph_stage_7"; isCluster="true"; label="Stage 7 (skipped)"; subgraph cluster_31 { id="cluster_31"; isCluster="true"; label="LocalTableScan"; 17 [id="node_17" labelType="html" label="ParallelCollectionRDD [17] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 18 [id="node_18" labelType="html" label="MapPartitionsRDD [18] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_29 { id="cluster_29"; isCluster="true"; label="Exchange"; 19 [id="node_19" labelType="html" label="MapPartitionsRDD [19] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 17->18; 18->19; }

digraph G { id="graph_8"; subgraph graph_stage_8 { id="graph_stage_8"; isCluster="true"; label="Stage 8 (skipped)"; subgraph cluster_32 { id="cluster_32"; isCluster="true"; label="LocalTableScan"; 11 [id="node_11" labelType="html" label="ParallelCollectionRDD [11] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 14 [id="node_14" labelType="html" label="MapPartitionsRDD [14] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_30 { id="cluster_30"; isCluster="true"; label="Exchange"; 15 [id="node_15" labelType="html" label="MapPartitionsRDD [15] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 11->14; 14->15; }

digraph G { id="graph_9"; subgraph graph_stage_9 { id="graph_stage_9"; isCluster="true"; label="Stage 9 (skipped)"; subgraph cluster_44 { id="cluster_44"; isCluster="true"; label="AQEShuffleRead"; 20 [id="node_20" labelType="html" label="ShuffledRowRDD [20] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_41 { id="cluster_41"; isCluster="true"; label="WholeStageCodegen (1)"; 21 [id="node_21" labelType="html" label="MapPartitionsRDD [21] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_49 { id="cluster_49"; isCluster="true"; label="AQEShuffleRead"; 22 [id="node_22" labelType="html" label="ShuffledRowRDD [22] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_46 { id="cluster_46"; isCluster="true"; label="WholeStageCodegen (2)"; 23 [id="node_23" labelType="html" label="MapPartitionsRDD [23] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_37 { id="cluster_37"; isCluster="true"; label="WholeStageCodegen (3)"; 24 [id="node_24" labelType="html" label="ZippedPartitionsRDD2 [24] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 25 [id="node_25" labelType="html" label="MapPartitionsRDD [25] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_36 { id="cluster_36"; isCluster="true"; label="Exchange"; 26 [id="node_26" labelType="html" label="MapPartitionsRDD [26] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 20->21; 22->23; 21->24; 23->24; 24->25; 25->26; }

19,20

15,22

digraph G { id="graph_10"; subgraph graph_stage_10 { id="graph_stage_10"; isCluster="true"; label="Stage 10 (skipped)"; subgraph cluster_34 { id="cluster_34"; isCluster="true"; label="LocalTableScan"; 12 [id="node_12" labelType="html" label="ParallelCollectionRDD [12] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 13 [id="node_13" labelType="html" label="MapPartitionsRDD [13] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_33 { id="cluster_33"; isCluster="true"; label="Exchange"; 16 [id="node_16" labelType="html" label="MapPartitionsRDD [16] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 12->13; 13->16; }

digraph G { id="graph_11"; subgraph graph_stage_11 { id="graph_stage_11"; isCluster="true"; label="Stage 11"; subgraph cluster_59 { id="cluster_59"; isCluster="true"; label="AQEShuffleRead"; 27 [id="node_27" labelType="html" label="ShuffledRowRDD [27] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_56 { id="cluster_56"; isCluster="true"; label="WholeStageCodegen (4)"; 28 [id="node_28" labelType="html" label="MapPartitionsRDD [28] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_64 { id="cluster_64"; isCluster="true"; label="AQEShuffleRead"; 29 [id="node_29" labelType="html" label="ShuffledRowRDD [29] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_61 { id="cluster_61"; isCluster="true"; label="WholeStageCodegen (5)"; 30 [id="node_30" labelType="html" label="MapPartitionsRDD [30] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_51 { id="cluster_51"; isCluster="true"; label="WholeStageCodegen (6)"; 31 [id="node_31" labelType="html" label="ZippedPartitionsRDD2 [31] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 32 [id="node_32" labelType="html" label="MapPartitionsRDD [32] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_50 { id="cluster_50"; isCluster="true"; label="WriteFiles"; 33 [id="node_33" labelType="html" label="MapPartitionsRDD [33] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 27->28; 29->30; 28->31; 30->31; 31->32; 32->33; }

26,27

16,29

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
11	tenants-pool-768	replenishmentRunId = 10000000279 tenantId = 1699186316786241789 activityType = PrepareStreams activityId = b7dd4133-4fdf-3440-8f6d-09069cda4413 workflowType = CalculateOrderProposalsWorkflow workflowId = 582cda42-a729-37d5-8166-0c493fa62be0 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-127007_1 scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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/04/10 15:02:11	3 s	1/1		29.4 KiB	294.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
10	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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)	Unknown	Unknown	0/1
9	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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)	Unknown	Unknown	0/1
8	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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)	Unknown	Unknown	0/1
7	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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)	Unknown	Unknown	0/1

Page:

Details for Job 7

Completed Stages (1)

Skipped Stages (4)