3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 784 (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 / 350
Output Size / Records:
71.2 KiB / 350
Associated Job Ids:
784
DAG Visualization
digraph G { subgraph clusterstage_784 { label="Stage 784"; subgraph cluster18431 { label="MicroBatchScan"; 8232 [labelType="html" label="DataSourceRDD [8232]<br>start at NativeMethodAccessorImpl.java:0"]; 8233 [labelType="html" label="MapPartitionsRDD [8233]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster18430 { label="Project"; 8234 [labelType="html" label="MapPartitionsRDD [8234]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster18426 { label="WholeStageCodegen (1)"; 8235 [labelType="html" label="MapPartitionsRDD [8235]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster18425 { label="Project"; 8236 [labelType="html" label="MapPartitionsRDD [8236]<br>start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster18424 { label="Sort"; 8237 [labelType="html" label="MapPartitionsRDD [8237]<br>start at NativeMethodAccessorImpl.java:0"]; } } 8232->8233; 8233->8234; 8234->8235; 8235->8236; 8236->8237; }
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