3.5.7
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
SP1
application UI
Details for Stage 21269 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Any: 1
Shuffle Read Size / Records:
365.3 KiB / 21591
Associated Job Ids:
10658
DAG Visualization
digraph G { subgraph clusterstage_21269 { label="Stage 21269"; subgraph cluster139436 { label="AQEShuffleRead"; 60508 [labelType="html" label="ShuffledRowRDD [60508] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139433 { label="WholeStageCodegen (7)"; 60509 [labelType="html" label="MapPartitionsRDD [60509] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139443 { label="AQEShuffleRead"; 60510 [labelType="html" label="ShuffledRowRDD [60510] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139442 { label="ObjectHashAggregate"; 60511 [labelType="html" label="MapPartitionsRDD [60511] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139438 { label="WholeStageCodegen (8)"; 60512 [labelType="html" label="MapPartitionsRDD [60512] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139429 { label="WholeStageCodegen (9)"; 60513 [labelType="html" label="ZippedPartitionsRDD2 [60513] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; 60514 [labelType="html" label="MapPartitionsRDD [60514] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster139444 { label="mapPartitionsInternal"; 60515 [labelType="html" label="MapPartitionsRDD [60515] [Unordered]<br>takeAsList at DataFrameCommonJob.java:145"]; } } 60508->60509; 60510->60511; 60511->60512; 60509->60513; 60512->60513; 60513->60514; 60514->60515; }
60507,60508
60499,60510
Event Timeline
Enable zooming
Tasks: 1. 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