crp-wrkload-determination - Details for Job 62

Status: SUCCEEDED
Submitted: 2026/09/05 17:55:46
Duration: 0.1 s
Associated SQL Query: 47
Job Group: 88c42b3e-f7b7-3812-8b16-7aa86f5ce414
Completed Stages: 1
Skipped Stages: 2

Enable zooming

digraph G { id="graph_132"; subgraph graph_stage_132 { id="graph_stage_132"; isCluster="true"; label="Stage 132 (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_133"; subgraph graph_stage_133 { id="graph_stage_133"; isCluster="true"; label="Stage 133 (skipped)"; 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_782 { id="cluster_782"; isCluster="true"; label="WholeStageCodegen (1)"; 295 [id="node_295" labelType="html" label="MapPartitionsRDD [295] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_781 { id="cluster_781"; isCluster="true"; label="ObjectHashAggregate"; 296 [id="node_296" labelType="html" label="MapPartitionsRDD [296] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_780 { id="cluster_780"; isCluster="true"; label="Exchange"; 297 [id="node_297" labelType="html" label="MapPartitionsRDD [297] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 277->278; 278->279; 279->280; 280->281; 281->282; 282->283; 283->295; 295->296; 296->297; }

276,277

283

digraph G { id="graph_134"; subgraph graph_stage_134 { id="graph_stage_134"; isCluster="true"; label="Stage 134"; subgraph cluster_787 { id="cluster_787"; isCluster="true"; label="Exchange"; 298 [id="node_298" labelType="html" label="ShuffledRowRDD [298] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_785 { id="cluster_785"; isCluster="true"; label="ObjectHashAggregate"; 299 [id="node_299" labelType="html" label="MapPartitionsRDD [299] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_788 { id="cluster_788"; isCluster="true"; label="mapPartitionsInternal"; 300 [id="node_300" labelType="html" label="MapPartitionsRDD [300] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 298->299; 299->300; }

297,298

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
134	tenants-pool-21	Delta: replenishmentRunId = 10000000003 tenantId = 5330363489248697092 activityType = DetermineWorkLoad activityId = 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 workflowType = ReplenishmentRunWorkflow workflowId = RP_SCH_5330363489248697092_5 attempt = 1 cornerstoneTenantId = 8495 marketUnit = MU_PPP_1 scenario = STANDARD: Compute snapshot for version: 0 $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:55:46	67 ms	1/1			5.3 KiB

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
133	default	$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)	Unknown	Unknown	0/50
132	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

133

default

$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)

Unknown

0/50

132

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: