3.5.5
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-wrkload-determination
application UI
Details for Stage 116020 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Process local: 10000
Associated Job Ids:
45027
DAG Visualization
digraph G { subgraph clusterstage_116020 { label="Stage 116020"; subgraph cluster543670 { label="repartition"; 194193 [labelType="html" label="ShuffledRDD [194193] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 194194 [labelType="html" label="CoalescedRDD [194194] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 194195 [labelType="html" label="MapPartitionsRDD [194195] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster543671 { label="mapPartitions"; 194196 [labelType="html" label="MapPartitionsRDD [194196] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster543675 { label="Scan"; 194197 [labelType="html" label="MapPartitionsRDD [194197] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster543674 { label="AppendColumnsWithObject"; 194198 [labelType="html" label="MapPartitionsRDD [194198] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster543673 { label="Exchange"; 194199 [labelType="html" label="MapPartitionsRDD [194199] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 194193->194194; 194194->194195; 194195->194196; 194196->194197; 194197->194198; 194198->194199; }
194192,194193
Event Timeline
Enable zooming
Tasks: 10000. 100 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time