3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 2497 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Process local: 50
Associated Job Ids:
832
DAG Visualization
digraph G { subgraph clusterstage_2497 { label="Stage 2497"; subgraph cluster1394 { label="Exchange"; 1264 [labelType="html" label="ShuffledRowRDD [1264] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1393 { label="HashAggregate"; 1265 [labelType="html" label="MapPartitionsRDD [1265] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1392 { label="StateStoreRestore"; 1266 [labelType="html" label="ReadStateStoreRDD [1266] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1391 { label="HashAggregate"; 1267 [labelType="html" label="MapPartitionsRDD [1267] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1390 { label="StateStoreSave"; 1268 [labelType="html" label="StateStoreRDD [1268] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1389 { label="HashAggregate"; 1269 [labelType="html" label="MapPartitionsRDD [1269] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1388 { label="Exchange"; 1270 [labelType="html" label="MapPartitionsRDD [1270] [Unordered]<br>run at <unknown>:0"]; 1271 [labelType="html" label="MapPartitionsRDD [1271] [Unordered]<br>run at <unknown>:0"]; } } 1264->1265; 1265->1266; 1266->1267; 1267->1268; 1268->1269; 1269->1270; 1270->1271; }
1263,1264
Event Timeline
Enable zooming
Tasks: 50. 1 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