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:
10 s
Locality Level Summary:
Process local: 50
Associated Job Ids:
320
DAG Visualization
digraph G { subgraph clusterstage_961 { label="Stage 961"; subgraph cluster526 { label="Exchange"; 487 [labelType="html" label="ShuffledRowRDD [487] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster523 { label="WholeStageCodegen (3)"; 488 [labelType="html" label="MapPartitionsRDD [488] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster522 { label="SortAggregate"; 489 [labelType="html" label="MapPartitionsRDD [489] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster521 { label="StateStoreRestore"; 490 [labelType="html" label="ReadStateStoreRDD [490] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster518 { label="WholeStageCodegen (4)"; 491 [labelType="html" label="MapPartitionsRDD [491] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster517 { label="SortAggregate"; 492 [labelType="html" label="MapPartitionsRDD [492] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster516 { label="StateStoreSave"; 493 [labelType="html" label="StateStoreRDD [493] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster513 { label="WholeStageCodegen (5)"; 494 [labelType="html" label="MapPartitionsRDD [494] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster512 { label="SortAggregate"; 495 [labelType="html" label="MapPartitionsRDD [495] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster509 { label="WholeStageCodegen (6)"; 496 [labelType="html" label="MapPartitionsRDD [496] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster508 { label="Exchange"; 497 [labelType="html" label="MapPartitionsRDD [497] [Unordered]<br>run at <unknown>:0"]; 498 [labelType="html" label="MapPartitionsRDD [498] [Unordered]<br>run at <unknown>:0"]; } } 487->488; 488->489; 489->490; 490->491; 491->492; 492->493; 493->494; 494->495; 495->496; 496->497; 497->498; }
486,487
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