crp-wrkload-determination - Details for Job 108

Status: SUCCEEDED
Submitted: 2026/09/05 18:20:33
Duration: 3 s
Associated SQL Query: 80
Job Group: 88c42b3e-f7b7-3812-8b16-7aa86f5ce414
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_233"; subgraph graph_stage_233 { id="graph_stage_233"; isCluster="true"; label="Stage 233 (skipped)"; subgraph cluster_728 { id="cluster_728"; isCluster="true"; label="Scan json "; 273 [id="node_273" labelType="html" label="FileScanRDD [273] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 274 [id="node_274" labelType="html" label="MapPartitionsRDD [274] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_725 { id="cluster_725"; isCluster="true"; label="WholeStageCodegen (1)"; 275 [id="node_275" labelType="html" label="MapPartitionsRDD [275] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_724 { id="cluster_724"; isCluster="true"; label="Exchange"; 276 [id="node_276" labelType="html" label="MapPartitionsRDD [276] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 273->274; 274->275; 275->276; }

digraph G { id="graph_234"; subgraph graph_stage_234 { id="graph_stage_234"; isCluster="true"; label="Stage 234"; 282 [id="node_282" labelType="html" label="SQLExecutionRDD [282] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; subgraph cluster_739 { id="cluster_739"; isCluster="true"; label="Exchange"; 277 [id="node_277" labelType="html" label="ShuffledRowRDD [277] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_734 { id="cluster_734"; isCluster="true"; label="WholeStageCodegen (2)"; 278 [id="node_278" labelType="html" label="MapPartitionsRDD [278] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_733 { id="cluster_733"; isCluster="true"; label="DeserializeToObject"; 279 [id="node_279" labelType="html" label="MapPartitionsRDD [279] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_732 { id="cluster_732"; isCluster="true"; label="MapPartitions"; 280 [id="node_280" labelType="html" label="MapPartitionsRDD [280] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_729 { id="cluster_729"; isCluster="true"; label="WholeStageCodegen (3)"; 281 [id="node_281" labelType="html" label="MapPartitionsRDD [281] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_740 { id="cluster_740"; isCluster="true"; label="map"; 283 [id="node_283" labelType="html" label="Delta Table State #0 - hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/workload-dupl-lock-v3/_delta_log [283] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_1331 { id="cluster_1331"; isCluster="true"; label="WholeStageCodegen (1)"; 489 [id="node_489" labelType="html" label="MapPartitionsRDD [489] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1330 { id="cluster_1330"; isCluster="true"; label="DeserializeToObject"; 490 [id="node_490" labelType="html" label="MapPartitionsRDD [490] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1329 { id="cluster_1329"; isCluster="true"; label="MapPartitions"; 491 [id="node_491" labelType="html" label="MapPartitionsRDD [491] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1324 { id="cluster_1324"; isCluster="true"; label="WholeStageCodegen (2)"; 492 [id="node_492" labelType="html" label="MapPartitionsRDD [492] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1323 { id="cluster_1323"; isCluster="true"; label="Exchange"; 493 [id="node_493" labelType="html" label="MapPartitionsRDD [493] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 277->278; 278->279; 279->280; 280->281; 281->282; 282->283; 283->489; 489->490; 490->491; 491->492; 492->493; }

276,277

283

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
234	tenants-pool-21	replenishmentRunId = 10000000003 tenantId = 5330363489248697092 activityType = DetermineWorkLoad activityId = 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 workflowType = ReplenishmentRunWorkflow workflowId = RP_SCH_5330363489248697092_5 attempt = 5 cornerstoneTenantId = 8495 marketUnit = MU_PPP_1 scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details RDD: Delta Table State #0 - hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/workload-dupl-lock-v3/_delta_log 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:20:33	2 s	50/50	1455.0 B

Page:

Skipped Stages (1)

Page:

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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

233

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/1

Page: