3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 558 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 3
Input Size / Records:
0.0 B / 423
Output Size / Records:
84.7 KiB / 423
Associated Job Ids:
558
DAG Visualization
digraph G { subgraph clusterstage_558 { label="Stage 558"; subgraph cluster13120 { label="MicroBatchScan"; 5859 [labelType="html" label="DataSourceRDD [5859]<br>start at NativeMethodAccessorImpl.java:0"]; 5860 [labelType="html" label="MapPartitionsRDD [5860]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster13119 { label="Project"; 5861 [labelType="html" label="MapPartitionsRDD [5861]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster13115 { label="WholeStageCodegen (1)"; 5862 [labelType="html" label="MapPartitionsRDD [5862]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster13114 { label="Project"; 5863 [labelType="html" label="MapPartitionsRDD [5863]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster13113 { label="Sort"; 5864 [labelType="html" label="MapPartitionsRDD [5864]<br>start at NativeMethodAccessorImpl.java:0"]; } } 5859->5860; 5860->5861; 5861->5862; 5862->5863; 5863->5864; }
Event Timeline
Enable zooming
Tasks: 3. 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