3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 1009 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
10 s
Locality Level Summary:
Process local: 50
Shuffle Read Size / Records:
248.0 B / 2
Shuffle Write Size / Records:
110.0 B / 1
Associated Job Ids:
336
DAG Visualization
digraph G { subgraph clusterstage_1009 { label="Stage 1009"; subgraph cluster549 { label="Exchange"; 514 [labelType="html" label="ShuffledRowRDD [514] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster548 { label="ObjectHashAggregate"; 515 [labelType="html" label="MapPartitionsRDD [515] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster547 { label="StateStoreRestore"; 516 [labelType="html" label="ReadStateStoreRDD [516] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster546 { label="ObjectHashAggregate"; 517 [labelType="html" label="MapPartitionsRDD [517] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster545 { label="StateStoreSave"; 518 [labelType="html" label="StateStoreRDD [518] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster544 { label="ObjectHashAggregate"; 519 [labelType="html" label="MapPartitionsRDD [519] [Unordered]<br>run at <unknown>:0"]; } subgraph cluster543 { label="Exchange"; 520 [labelType="html" label="MapPartitionsRDD [520] [Unordered]<br>run at <unknown>:0"]; 521 [labelType="html" label="MapPartitionsRDD [521] [Unordered]<br>run at <unknown>:0"]; } } 514->515; 515->516; 516->517; 517->518; 518->519; 519->520; 520->521; }
513,514
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