crp-wrkload-determination - Details for Job 10

Status: SUCCEEDED
Submitted: 2026/09/05 08:01:57
Duration: 2 s
Associated SQL Query: 8
Job Group: 66b169fa-26f2-32c1-8f73-e571f2d5e18b
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_17"; subgraph graph_stage_17 { id="graph_stage_17"; isCluster="true"; label="Stage 17 (skipped)"; subgraph cluster_92 { id="cluster_92"; isCluster="true"; label="LocalTableScan"; 31 [id="node_31" labelType="html" label="ParallelCollectionRDD [31] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 33 [id="node_33" labelType="html" label="MapPartitionsRDD [33] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_90 { id="cluster_90"; isCluster="true"; label="Exchange"; 35 [id="node_35" labelType="html" label="MapPartitionsRDD [35] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 31->33; 33->35; }

digraph G { id="graph_18"; subgraph graph_stage_18 { id="graph_stage_18"; isCluster="true"; label="Stage 18 (skipped)"; subgraph cluster_86 { id="cluster_86"; isCluster="true"; label="LocalTableScan"; 36 [id="node_36" labelType="html" label="ParallelCollectionRDD [36] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 37 [id="node_37" labelType="html" label="MapPartitionsRDD [37] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_85 { id="cluster_85"; isCluster="true"; label="Exchange"; 38 [id="node_38" labelType="html" label="MapPartitionsRDD [38] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 36->37; 37->38; }

digraph G { id="graph_19"; subgraph graph_stage_19 { id="graph_stage_19"; isCluster="true"; label="Stage 19 (skipped)"; subgraph cluster_91 { id="cluster_91"; isCluster="true"; label="LocalTableScan"; 30 [id="node_30" labelType="html" label="ParallelCollectionRDD [30] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 32 [id="node_32" labelType="html" label="MapPartitionsRDD [32] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_88 { id="cluster_88"; isCluster="true"; label="Exchange"; 34 [id="node_34" labelType="html" label="MapPartitionsRDD [34] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 30->32; 32->34; }

digraph G { id="graph_20"; subgraph graph_stage_20 { id="graph_stage_20"; isCluster="true"; label="Stage 20 (skipped)"; subgraph cluster_102 { id="cluster_102"; isCluster="true"; label="AQEShuffleRead"; 39 [id="node_39" labelType="html" label="ShuffledRowRDD [39] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_99 { id="cluster_99"; isCluster="true"; label="WholeStageCodegen (1)"; 40 [id="node_40" labelType="html" label="MapPartitionsRDD [40] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_107 { id="cluster_107"; isCluster="true"; label="AQEShuffleRead"; 41 [id="node_41" labelType="html" label="ShuffledRowRDD [41] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_104 { id="cluster_104"; isCluster="true"; label="WholeStageCodegen (2)"; 42 [id="node_42" labelType="html" label="MapPartitionsRDD [42] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_95 { id="cluster_95"; isCluster="true"; label="WholeStageCodegen (3)"; 43 [id="node_43" labelType="html" label="ZippedPartitionsRDD2 [43] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 44 [id="node_44" labelType="html" label="MapPartitionsRDD [44] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_94 { id="cluster_94"; isCluster="true"; label="Exchange"; 45 [id="node_45" labelType="html" label="MapPartitionsRDD [45] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 39->40; 41->42; 40->43; 42->43; 43->44; 44->45; }

38,39

34,41

digraph G { id="graph_21"; subgraph graph_stage_21 { id="graph_stage_21"; isCluster="true"; label="Stage 21"; subgraph cluster_117 { id="cluster_117"; isCluster="true"; label="AQEShuffleRead"; 46 [id="node_46" labelType="html" label="ShuffledRowRDD [46] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_114 { id="cluster_114"; isCluster="true"; label="WholeStageCodegen (4)"; 47 [id="node_47" labelType="html" label="MapPartitionsRDD [47] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_122 { id="cluster_122"; isCluster="true"; label="AQEShuffleRead"; 48 [id="node_48" labelType="html" label="ShuffledRowRDD [48] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_119 { id="cluster_119"; isCluster="true"; label="WholeStageCodegen (5)"; 49 [id="node_49" labelType="html" label="MapPartitionsRDD [49] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_109 { id="cluster_109"; isCluster="true"; label="WholeStageCodegen (6)"; 50 [id="node_50" labelType="html" label="ZippedPartitionsRDD2 [50] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 51 [id="node_51" labelType="html" label="MapPartitionsRDD [51] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_108 { id="cluster_108"; isCluster="true"; label="WriteFiles"; 52 [id="node_52" labelType="html" label="MapPartitionsRDD [52] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 46->47; 48->49; 47->50; 49->50; 50->51; 51->52; }

45,46

35,48

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
21	tenants-pool-21	replenishmentRunId = 10000000002 tenantId = 5330363489248697092 activityType = DetermineWorkLoad activityId = 66b169fa-26f2-32c1-8f73-e571f2d5e18b workflowType = ReplenishmentRunWorkflow workflowId = RP_SCH_5330363489248697092_4 attempt = 1 cornerstoneTenantId = 8495 marketUnit = MU_PPP_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/09/05 08:01:57	2 s	1/1		32.9 KiB	1957.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
20	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
19	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/3
18	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/3
17	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/3

Page: