3.5.7
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
EVAL1_SPC1
application UI
Details for Stage 532 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 26
Input Size / Records:
5.8 MiB / 29428
Shuffle Write Size / Records:
3.2 MiB / 617988
Associated Job Ids:
264
DAG Visualization
digraph G { subgraph clusterstage_532 { label="Stage 532"; subgraph cluster7138 { label="Scan parquet "; 2736 [labelType="html" label="FileScanRDD [2736]<br>takeAsList at DataFrameCommonJob.java:145"]; 2737 [labelType="html" label="MapPartitionsRDD [2737]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7134 { label="WholeStageCodegen (1)"; 2738 [labelType="html" label="MapPartitionsRDD [2738]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7143 { label="Scan parquet "; 2739 [labelType="html" label="FileScanRDD [2739]<br>takeAsList at DataFrameCommonJob.java:145"]; 2740 [labelType="html" label="MapPartitionsRDD [2740]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7139 { label="WholeStageCodegen (2)"; 2741 [labelType="html" label="MapPartitionsRDD [2741]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7148 { label="Scan parquet "; 2742 [labelType="html" label="FileScanRDD [2742]<br>takeAsList at DataFrameCommonJob.java:145"]; 2743 [labelType="html" label="MapPartitionsRDD [2743]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7144 { label="WholeStageCodegen (3)"; 2744 [labelType="html" label="MapPartitionsRDD [2744]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7153 { label="Scan parquet "; 2745 [labelType="html" label="FileScanRDD [2745]<br>takeAsList at DataFrameCommonJob.java:145"]; 2746 [labelType="html" label="MapPartitionsRDD [2746]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7149 { label="WholeStageCodegen (4)"; 2747 [labelType="html" label="MapPartitionsRDD [2747]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7158 { label="Scan parquet "; 2748 [labelType="html" label="FileScanRDD [2748]<br>takeAsList at DataFrameCommonJob.java:145"]; 2749 [labelType="html" label="MapPartitionsRDD [2749]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7154 { label="WholeStageCodegen (5)"; 2750 [labelType="html" label="MapPartitionsRDD [2750]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7163 { label="Scan parquet "; 2751 [labelType="html" label="FileScanRDD [2751]<br>takeAsList at DataFrameCommonJob.java:145"]; 2752 [labelType="html" label="MapPartitionsRDD [2752]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7159 { label="WholeStageCodegen (6)"; 2753 [labelType="html" label="MapPartitionsRDD [2753]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7168 { label="Scan parquet "; 2754 [labelType="html" label="FileScanRDD [2754]<br>takeAsList at DataFrameCommonJob.java:145"]; 2755 [labelType="html" label="MapPartitionsRDD [2755]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7164 { label="WholeStageCodegen (7)"; 2756 [labelType="html" label="MapPartitionsRDD [2756]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7173 { label="Scan parquet "; 2757 [labelType="html" label="FileScanRDD [2757]<br>takeAsList at DataFrameCommonJob.java:145"]; 2758 [labelType="html" label="MapPartitionsRDD [2758]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7169 { label="WholeStageCodegen (8)"; 2759 [labelType="html" label="MapPartitionsRDD [2759]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7178 { label="Scan parquet "; 2760 [labelType="html" label="FileScanRDD [2760]<br>takeAsList at DataFrameCommonJob.java:145"]; 2761 [labelType="html" label="MapPartitionsRDD [2761]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7174 { label="WholeStageCodegen (9)"; 2762 [labelType="html" label="MapPartitionsRDD [2762]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7183 { label="Scan parquet "; 2763 [labelType="html" label="FileScanRDD [2763]<br>takeAsList at DataFrameCommonJob.java:145"]; 2764 [labelType="html" label="MapPartitionsRDD [2764]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7179 { label="WholeStageCodegen (10)"; 2765 [labelType="html" label="MapPartitionsRDD [2765]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7188 { label="Scan parquet "; 2766 [labelType="html" label="FileScanRDD [2766]<br>takeAsList at DataFrameCommonJob.java:145"]; 2767 [labelType="html" label="MapPartitionsRDD [2767]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7184 { label="WholeStageCodegen (11)"; 2768 [labelType="html" label="MapPartitionsRDD [2768]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7193 { label="Scan parquet "; 2769 [labelType="html" label="FileScanRDD [2769]<br>takeAsList at DataFrameCommonJob.java:145"]; 2770 [labelType="html" label="MapPartitionsRDD [2770]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7189 { label="WholeStageCodegen (12)"; 2771 [labelType="html" label="MapPartitionsRDD [2771]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7198 { label="Scan parquet "; 2772 [labelType="html" label="FileScanRDD [2772]<br>takeAsList at DataFrameCommonJob.java:145"]; 2773 [labelType="html" label="MapPartitionsRDD [2773]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7194 { label="WholeStageCodegen (13)"; 2774 [labelType="html" label="MapPartitionsRDD [2774]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7133 { label="Union"; 2775 [labelType="html" label="UnionRDD [2775]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7129 { label="WholeStageCodegen (14)"; 2776 [labelType="html" label="MapPartitionsRDD [2776]<br>takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7128 { label="Exchange"; 2777 [labelType="html" label="MapPartitionsRDD [2777]<br>takeAsList at DataFrameCommonJob.java:145"]; } } 2736->2737; 2737->2738; 2739->2740; 2740->2741; 2742->2743; 2743->2744; 2745->2746; 2746->2747; 2748->2749; 2749->2750; 2751->2752; 2752->2753; 2754->2755; 2755->2756; 2757->2758; 2758->2759; 2760->2761; 2761->2762; 2763->2764; 2764->2765; 2766->2767; 2767->2768; 2769->2770; 2770->2771; 2772->2773; 2773->2774; 2738->2775; 2741->2775; 2744->2775; 2747->2775; 2750->2775; 2753->2775; 2756->2775; 2759->2775; 2762->2775; 2765->2775; 2768->2775; 2771->2775; 2774->2775; 2775->2776; 2776->2777; }
Event Timeline
Enable zooming
Tasks: 26. 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