3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 1825 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 s
Locality Level Summary:
Process local: 50
Associated Job Ids:
608
DAG Visualization
digraph G { subgraph clusterstage_1825 { label="Stage 1825"; subgraph cluster1032 { label="Exchange"; 926 [labelType="html" label="ShuffledRowRDD [926] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1029 { label="WholeStageCodegen (2)"; 927 [labelType="html" label="MapPartitionsRDD [927] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1028 { label="SortAggregate"; 928 [labelType="html" label="MapPartitionsRDD [928] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1027 { label="StateStoreRestore"; 929 [labelType="html" label="ReadStateStoreRDD [929] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1024 { label="WholeStageCodegen (3)"; 930 [labelType="html" label="MapPartitionsRDD [930] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1023 { label="SortAggregate"; 931 [labelType="html" label="MapPartitionsRDD [931] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1022 { label="StateStoreSave"; 932 [labelType="html" label="StateStoreRDD [932] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1019 { label="WholeStageCodegen (4)"; 933 [labelType="html" label="MapPartitionsRDD [933] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1018 { label="SortAggregate"; 934 [labelType="html" label="MapPartitionsRDD [934] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1015 { label="WholeStageCodegen (5)"; 935 [labelType="html" label="MapPartitionsRDD [935] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster1014 { label="Exchange"; 936 [labelType="html" label="MapPartitionsRDD [936] [Unordered]<br>run at <unknown>:0"]; 937 [labelType="html" label="MapPartitionsRDD [937] [Unordered]<br>run at <unknown>:0"]; } } 926->927; 927->928; 928->929; 929->930; 930->931; 931->932; 932->933; 933->934; 934->935; 935->936; 936->937; }
925,926
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