3.5.7
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
SP1
application UI
Details for Stage 7840 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Process local: 45
Input Size / Records:
759.5 KiB / 3934
Shuffle Write Size / Records:
206.5 KiB / 3419
Associated Job Ids:
3833
DAG Visualization
digraph G { subgraph clusterstage_7840 { label="Stage 7840"; subgraph cluster51012 { label="Scan csv "; 22552 [labelType="html" label="FileScanRDD [22552]<br>rdd at PersistJob.java:28"]; 22553 [labelType="html" label="MapPartitionsRDD [22553]<br>rdd at PersistJob.java:28"]; } subgraph cluster51007 { label="WholeStageCodegen (1)"; 22554 [labelType="html" label="MapPartitionsRDD [22554]<br>rdd at PersistJob.java:28"]; } subgraph cluster51019 { label="Scan parquet "; 22555 [labelType="html" label="FileScanRDD [22555]<br>rdd at PersistJob.java:28"]; 22556 [labelType="html" label="MapPartitionsRDD [22556]<br>rdd at PersistJob.java:28"]; } subgraph cluster51013 { label="WholeStageCodegen (2)"; 22557 [labelType="html" label="MapPartitionsRDD [22557]<br>rdd at PersistJob.java:28"]; } subgraph cluster51026 { label="Scan parquet "; 22558 [labelType="html" label="FileScanRDD [22558]<br>rdd at PersistJob.java:28"]; 22559 [labelType="html" label="MapPartitionsRDD [22559]<br>rdd at PersistJob.java:28"]; } subgraph cluster51020 { label="WholeStageCodegen (3)"; 22560 [labelType="html" label="MapPartitionsRDD [22560]<br>rdd at PersistJob.java:28"]; } subgraph cluster51033 { label="Scan parquet "; 22561 [labelType="html" label="FileScanRDD [22561]<br>rdd at PersistJob.java:28"]; 22562 [labelType="html" label="MapPartitionsRDD [22562]<br>rdd at PersistJob.java:28"]; } subgraph cluster51027 { label="WholeStageCodegen (4)"; 22563 [labelType="html" label="MapPartitionsRDD [22563]<br>rdd at PersistJob.java:28"]; } subgraph cluster51040 { label="Scan parquet "; 22564 [labelType="html" label="FileScanRDD [22564]<br>rdd at PersistJob.java:28"]; 22565 [labelType="html" label="MapPartitionsRDD [22565]<br>rdd at PersistJob.java:28"]; } subgraph cluster51034 { label="WholeStageCodegen (5)"; 22566 [labelType="html" label="MapPartitionsRDD [22566]<br>rdd at PersistJob.java:28"]; } subgraph cluster51047 { label="Scan parquet "; 22567 [labelType="html" label="FileScanRDD [22567]<br>rdd at PersistJob.java:28"]; 22568 [labelType="html" label="MapPartitionsRDD [22568]<br>rdd at PersistJob.java:28"]; } subgraph cluster51041 { label="WholeStageCodegen (6)"; 22569 [labelType="html" label="MapPartitionsRDD [22569]<br>rdd at PersistJob.java:28"]; } subgraph cluster51054 { label="Scan parquet "; 22570 [labelType="html" label="FileScanRDD [22570]<br>rdd at PersistJob.java:28"]; 22571 [labelType="html" label="MapPartitionsRDD [22571]<br>rdd at PersistJob.java:28"]; } subgraph cluster51048 { label="WholeStageCodegen (7)"; 22572 [labelType="html" label="MapPartitionsRDD [22572]<br>rdd at PersistJob.java:28"]; } subgraph cluster51061 { label="Scan parquet "; 22573 [labelType="html" label="FileScanRDD [22573]<br>rdd at PersistJob.java:28"]; 22574 [labelType="html" label="MapPartitionsRDD [22574]<br>rdd at PersistJob.java:28"]; } subgraph cluster51055 { label="WholeStageCodegen (8)"; 22575 [labelType="html" label="MapPartitionsRDD [22575]<br>rdd at PersistJob.java:28"]; } subgraph cluster51068 { label="Scan parquet "; 22576 [labelType="html" label="FileScanRDD [22576]<br>rdd at PersistJob.java:28"]; 22577 [labelType="html" label="MapPartitionsRDD [22577]<br>rdd at PersistJob.java:28"]; } subgraph cluster51062 { label="WholeStageCodegen (9)"; 22578 [labelType="html" label="MapPartitionsRDD [22578]<br>rdd at PersistJob.java:28"]; } subgraph cluster51075 { label="Scan parquet "; 22579 [labelType="html" label="FileScanRDD [22579]<br>rdd at PersistJob.java:28"]; 22580 [labelType="html" label="MapPartitionsRDD [22580]<br>rdd at PersistJob.java:28"]; } subgraph cluster51069 { label="WholeStageCodegen (10)"; 22581 [labelType="html" label="MapPartitionsRDD [22581]<br>rdd at PersistJob.java:28"]; } subgraph cluster51082 { label="Scan parquet "; 22582 [labelType="html" label="FileScanRDD [22582]<br>rdd at PersistJob.java:28"]; 22583 [labelType="html" label="MapPartitionsRDD [22583]<br>rdd at PersistJob.java:28"]; } subgraph cluster51076 { label="WholeStageCodegen (11)"; 22584 [labelType="html" label="MapPartitionsRDD [22584]<br>rdd at PersistJob.java:28"]; } subgraph cluster51006 { label="Union"; 22585 [labelType="html" label="UnionRDD [22585]<br>rdd at PersistJob.java:28"]; } subgraph cluster50995 { label="WholeStageCodegen (12)"; 22586 [labelType="html" label="MapPartitionsRDD [22586]<br>rdd at PersistJob.java:28"]; } subgraph cluster50994 { label="Exchange"; 22587 [labelType="html" label="MapPartitionsRDD [22587]<br>rdd at PersistJob.java:28"]; } } 22552->22553; 22553->22554; 22555->22556; 22556->22557; 22558->22559; 22559->22560; 22561->22562; 22562->22563; 22564->22565; 22565->22566; 22567->22568; 22568->22569; 22570->22571; 22571->22572; 22573->22574; 22574->22575; 22576->22577; 22577->22578; 22579->22580; 22580->22581; 22582->22583; 22583->22584; 22554->22585; 22557->22585; 22560->22585; 22563->22585; 22566->22585; 22569->22585; 22572->22585; 22575->22585; 22578->22585; 22581->22585; 22584->22585; 22585->22586; 22586->22587; }
Event Timeline
Enable zooming
Tasks: 45. 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