3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 2593 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
7 s
Locality Level Summary:
Process local: 50
Shuffle Read Size / Records:
253.0 B / 2
Shuffle Write Size / Records:
291.0 B / 2
Associated Job Ids:
864
DAG Visualization
digraph G { subgraph clusterstage_2593 { label="Stage 2593"; subgraph cluster1446 { label="Exchange"; 1311 [labelType="html" label="ShuffledRowRDD [1311] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1445 { label="ObjectHashAggregate"; 1312 [labelType="html" label="MapPartitionsRDD [1312] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1444 { label="StateStoreRestore"; 1313 [labelType="html" label="ReadStateStoreRDD [1313] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1443 { label="ObjectHashAggregate"; 1314 [labelType="html" label="MapPartitionsRDD [1314] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1442 { label="StateStoreSave"; 1315 [labelType="html" label="StateStoreRDD [1315] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1441 { label="ObjectHashAggregate"; 1316 [labelType="html" label="MapPartitionsRDD [1316] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1440 { label="Exchange"; 1317 [labelType="html" label="MapPartitionsRDD [1317] [Unordered]<br>run at <unknown>:0"]; 1318 [labelType="html" label="MapPartitionsRDD [1318] [Unordered]<br>run at <unknown>:0"]; } } 1311->1312; 1312->1313; 1313->1314; 1314->1315; 1315->1316; 1316->1317; 1317->1318; }
1310,1311
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