crp-wrkload-determination - Details for Job 76

Status: SUCCEEDED
Submitted: 2026/09/05 17:57:53
Duration: 0.6 s
Associated SQL Query: 56
Job Group: 88c42b3e-f7b7-3812-8b16-7aa86f5ce414
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_159"; subgraph graph_stage_159 { id="graph_stage_159"; isCluster="true"; label="Stage 159 (skipped)"; subgraph cluster_898 { id="cluster_898"; isCluster="true"; label="LocalTableScan"; 341 [id="node_341" labelType="html" label="ParallelCollectionRDD [341] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 342 [id="node_342" labelType="html" label="MapPartitionsRDD [342] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_897 { id="cluster_897"; isCluster="true"; label="Exchange"; 343 [id="node_343" labelType="html" label="MapPartitionsRDD [343] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 341->342; 342->343; }

digraph G { id="graph_160"; subgraph graph_stage_160 { id="graph_stage_160"; isCluster="true"; label="Stage 160 (skipped)"; subgraph cluster_901 { id="cluster_901"; isCluster="true"; label="LocalTableScan"; 335 [id="node_335" labelType="html" label="ParallelCollectionRDD [335] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 337 [id="node_337" labelType="html" label="MapPartitionsRDD [337] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_900 { id="cluster_900"; isCluster="true"; label="Exchange"; 338 [id="node_338" labelType="html" label="MapPartitionsRDD [338] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 335->337; 337->338; }

digraph G { id="graph_161"; subgraph graph_stage_161 { id="graph_stage_161"; isCluster="true"; label="Stage 161 (skipped)"; subgraph cluster_914 { id="cluster_914"; isCluster="true"; label="AQEShuffleRead"; 344 [id="node_344" labelType="html" label="ShuffledRowRDD [344] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_911 { id="cluster_911"; isCluster="true"; label="WholeStageCodegen (1)"; 345 [id="node_345" labelType="html" label="MapPartitionsRDD [345] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_919 { id="cluster_919"; isCluster="true"; label="AQEShuffleRead"; 346 [id="node_346" labelType="html" label="ShuffledRowRDD [346] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_916 { id="cluster_916"; isCluster="true"; label="WholeStageCodegen (2)"; 347 [id="node_347" labelType="html" label="MapPartitionsRDD [347] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_907 { id="cluster_907"; isCluster="true"; label="WholeStageCodegen (3)"; 348 [id="node_348" labelType="html" label="ZippedPartitionsRDD2 [348] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 349 [id="node_349" labelType="html" label="MapPartitionsRDD [349] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_906 { id="cluster_906"; isCluster="true"; label="Exchange"; 350 [id="node_350" labelType="html" label="MapPartitionsRDD [350] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 344->345; 346->347; 345->348; 347->348; 348->349; 349->350; }

343,344

338,346

digraph G { id="graph_162"; subgraph graph_stage_162 { id="graph_stage_162"; isCluster="true"; label="Stage 162 (skipped)"; subgraph cluster_904 { id="cluster_904"; isCluster="true"; label="LocalTableScan"; 336 [id="node_336" labelType="html" label="ParallelCollectionRDD [336] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 339 [id="node_339" labelType="html" label="MapPartitionsRDD [339] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_903 { id="cluster_903"; isCluster="true"; label="Exchange"; 340 [id="node_340" labelType="html" label="MapPartitionsRDD [340] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 336->339; 339->340; }

digraph G { id="graph_163"; subgraph graph_stage_163 { id="graph_stage_163"; isCluster="true"; label="Stage 163"; subgraph cluster_929 { id="cluster_929"; isCluster="true"; label="AQEShuffleRead"; 351 [id="node_351" labelType="html" label="ShuffledRowRDD [351] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_926 { id="cluster_926"; isCluster="true"; label="WholeStageCodegen (4)"; 352 [id="node_352" labelType="html" label="MapPartitionsRDD [352] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_934 { id="cluster_934"; isCluster="true"; label="AQEShuffleRead"; 353 [id="node_353" labelType="html" label="ShuffledRowRDD [353] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_931 { id="cluster_931"; isCluster="true"; label="WholeStageCodegen (5)"; 354 [id="node_354" labelType="html" label="MapPartitionsRDD [354] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_921 { id="cluster_921"; isCluster="true"; label="WholeStageCodegen (6)"; 355 [id="node_355" labelType="html" label="ZippedPartitionsRDD2 [355] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 356 [id="node_356" labelType="html" label="MapPartitionsRDD [356] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_920 { id="cluster_920"; isCluster="true"; label="WriteFiles"; 357 [id="node_357" labelType="html" label="MapPartitionsRDD [357] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 351->352; 353->354; 352->355; 354->355; 355->356; 356->357; }

350,351

340,353

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
163	tenants-pool-21	replenishmentRunId = 10000000003 tenantId = 5330363489248697092 activityType = DetermineWorkLoad activityId = 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 workflowType = ReplenishmentRunWorkflow workflowId = RP_SCH_5330363489248697092_5 attempt = 2 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 17:57:53	0.6 s	1/1		32.3 KiB	950.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
162	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
161	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
160	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
159	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: