3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 961 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
9 s
Locality Level Summary:
Process local: 50
Shuffle Read Size / Records:
780.0 B / 3
Associated Job Ids:
320
DAG Visualization
digraph G { subgraph clusterstage_961 { label="Stage 961"; subgraph cluster552 { label="Exchange"; 495 [labelType="html" label="ShuffledRowRDD [495] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster549 { label="WholeStageCodegen (3)"; 496 [labelType="html" label="MapPartitionsRDD [496] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster548 { label="SortAggregate"; 497 [labelType="html" label="MapPartitionsRDD [497] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster547 { label="StateStoreRestore"; 498 [labelType="html" label="ReadStateStoreRDD [498] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster544 { label="WholeStageCodegen (4)"; 499 [labelType="html" label="MapPartitionsRDD [499] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster543 { label="SortAggregate"; 500 [labelType="html" label="MapPartitionsRDD [500] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster542 { label="StateStoreSave"; 501 [labelType="html" label="StateStoreRDD [501] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster539 { label="WholeStageCodegen (5)"; 502 [labelType="html" label="MapPartitionsRDD [502] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster538 { label="SortAggregate"; 503 [labelType="html" label="MapPartitionsRDD [503] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster535 { label="WholeStageCodegen (6)"; 504 [labelType="html" label="MapPartitionsRDD [504] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster534 { label="Exchange"; 505 [labelType="html" label="MapPartitionsRDD [505] [Unordered]<br>run at <unknown>:0"]; 506 [labelType="html" label="MapPartitionsRDD [506] [Unordered]<br>run at <unknown>:0"]; } } 495->496; 496->497; 497->498; 498->499; 499->500; 500->501; 501->502; 502->503; 503->504; 504->505; 505->506; }
494,495
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