crp-wrkload-determination - Details for Job 75

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

Enable zooming

digraph G { id="graph_156"; subgraph graph_stage_156 { id="graph_stage_156"; isCluster="true"; label="Stage 156 (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_157"; subgraph graph_stage_157 { id="graph_stage_157"; isCluster="true"; label="Stage 157 (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_158"; subgraph graph_stage_158 { id="graph_stage_158"; isCluster="true"; label="Stage 158"; 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

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
158	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	29 ms	1/1			896.0 B	624.0 B

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
157	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
156	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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

157

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

0/3

156

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

0/3

Page: