crp-wrkload-determination - Details for Job 83

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

Enable zooming

digraph G { id="graph_172"; subgraph graph_stage_172 { id="graph_stage_172"; isCluster="true"; label="Stage 172 (skipped)"; subgraph cluster_988 { id="cluster_988"; isCluster="true"; label="LocalTableScan"; 373 [id="node_373" labelType="html" label="ParallelCollectionRDD [373] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 374 [id="node_374" labelType="html" label="MapPartitionsRDD [374] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_987 { id="cluster_987"; isCluster="true"; label="Exchange"; 375 [id="node_375" labelType="html" label="MapPartitionsRDD [375] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 373->374; 374->375; }

digraph G { id="graph_173"; subgraph graph_stage_173 { id="graph_stage_173"; isCluster="true"; label="Stage 173 (skipped)"; subgraph cluster_991 { id="cluster_991"; isCluster="true"; label="LocalTableScan"; 367 [id="node_367" labelType="html" label="ParallelCollectionRDD [367] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 369 [id="node_369" labelType="html" label="MapPartitionsRDD [369] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_990 { id="cluster_990"; isCluster="true"; label="Exchange"; 372 [id="node_372" labelType="html" label="MapPartitionsRDD [372] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 367->369; 369->372; }

digraph G { id="graph_174"; subgraph graph_stage_174 { id="graph_stage_174"; isCluster="true"; label="Stage 174"; subgraph cluster_1004 { id="cluster_1004"; isCluster="true"; label="AQEShuffleRead"; 376 [id="node_376" labelType="html" label="ShuffledRowRDD [376] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1001 { id="cluster_1001"; isCluster="true"; label="WholeStageCodegen (1)"; 377 [id="node_377" labelType="html" label="MapPartitionsRDD [377] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1009 { id="cluster_1009"; isCluster="true"; label="AQEShuffleRead"; 378 [id="node_378" labelType="html" label="ShuffledRowRDD [378] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1006 { id="cluster_1006"; isCluster="true"; label="WholeStageCodegen (2)"; 379 [id="node_379" labelType="html" label="MapPartitionsRDD [379] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_997 { id="cluster_997"; isCluster="true"; label="WholeStageCodegen (3)"; 380 [id="node_380" labelType="html" label="ZippedPartitionsRDD2 [380] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 381 [id="node_381" labelType="html" label="MapPartitionsRDD [381] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_996 { id="cluster_996"; isCluster="true"; label="Exchange"; 382 [id="node_382" labelType="html" label="MapPartitionsRDD [382] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 376->377; 378->379; 377->380; 379->380; 380->381; 381->382; }

375,376

372,378

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
174	tenants-pool-21	replenishmentRunId = 10000000003 tenantId = 5330363489248697092 activityType = DetermineWorkLoad activityId = 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 workflowType = ReplenishmentRunWorkflow workflowId = RP_SCH_5330363489248697092_5 attempt = 3 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 18:01:57	27 ms	1/1			884.0 B	606.0 B

Page:

Skipped Stages (2)

Page:

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

173

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

172

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: