3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 864 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Process local: 28
Input Size / Records:
0.0 B / 28
Shuffle Write Size / Records:
3.4 KiB / 28
Associated Job Ids:
288
DAG Visualization
digraph G { subgraph clusterstage_864 { label="Stage 864"; subgraph cluster481 { label="MicroBatchScan"; 432 [labelType="html" label="DataSourceRDD [432]<br>run at <unknown>:0"]; 433 [labelType="html" label="MapPartitionsRDD [433]<br>run at <unknown>:0"]; } subgraph cluster480 { label="Filter"; 434 [labelType="html" label="MapPartitionsRDD [434]<br>run at <unknown>:0"]; } subgraph cluster479 { label="Project"; 435 [labelType="html" label="MapPartitionsRDD [435]<br>run at <unknown>:0"]; } subgraph cluster476 { label="WholeStageCodegen (1)"; 436 [labelType="html" label="MapPartitionsRDD [436]<br>run at <unknown>:0"]; } subgraph cluster475 { label="EventTimeWatermark"; 437 [labelType="html" label="MapPartitionsRDD [437]<br>run at <unknown>:0"]; } subgraph cluster472 { label="WholeStageCodegen (2)"; 438 [labelType="html" label="MapPartitionsRDD [438]<br>run at <unknown>:0"]; } subgraph cluster471 { label="ObjectHashAggregate"; 439 [labelType="html" label="MapPartitionsRDD [439]<br>run at <unknown>:0"]; } subgraph cluster470 { label="Exchange"; 440 [labelType="html" label="MapPartitionsRDD [440]<br>run at <unknown>:0"]; } } 432->433; 433->434; 434->435; 435->436; 436->437; 437->438; 438->439; 439->440; }
Event Timeline
Enable zooming
Tasks: 28. 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