3.5.0
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
AdsHub Analysis Processor
application UI
Details for Stage 2400 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 2
Input Size / Records:
0.0 B / 2
Shuffle Write Size / Records:
259.0 B / 2
Associated Job Ids:
800
DAG Visualization
digraph G { subgraph clusterstage_2400 { label="Stage 2400"; subgraph cluster1348 { label="MicroBatchScan"; 1205 [labelType="html" label="DataSourceRDD [1205]<br>run at <unknown>:0"]; 1206 [labelType="html" label="MapPartitionsRDD [1206]<br>run at <unknown>:0"]; } subgraph cluster1347 { label="Filter"; 1207 [labelType="html" label="MapPartitionsRDD [1207]<br>run at <unknown>:0"]; } subgraph cluster1346 { label="Project"; 1208 [labelType="html" label="MapPartitionsRDD [1208]<br>run at <unknown>:0"]; } subgraph cluster1343 { label="WholeStageCodegen (1)"; 1209 [labelType="html" label="MapPartitionsRDD [1209]<br>run at <unknown>:0"]; } subgraph cluster1342 { label="EventTimeWatermark"; 1210 [labelType="html" label="MapPartitionsRDD [1210]<br>run at <unknown>:0"]; } subgraph cluster1339 { label="WholeStageCodegen (2)"; 1211 [labelType="html" label="MapPartitionsRDD [1211]<br>run at <unknown>:0"]; } subgraph cluster1338 { label="ObjectHashAggregate"; 1212 [labelType="html" label="MapPartitionsRDD [1212]<br>run at <unknown>:0"]; } subgraph cluster1337 { label="Exchange"; 1213 [labelType="html" label="MapPartitionsRDD [1213]<br>run at <unknown>:0"]; } } 1205->1206; 1206->1207; 1207->1208; 1208->1209; 1209->1210; 1210->1211; 1211->1212; 1212->1213; }
Event Timeline
Enable zooming
Tasks: 2. 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