3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 772 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 3
Input Size / Records:
0.0 B / 444
Associated Job Ids:
772
DAG Visualization
digraph G { subgraph clusterstage_772 { label="Stage 772"; 8110 [labelType="html" label="SQLExecutionRDD [8110]<br>run at <unknown>:0"]; 8118 [labelType="html" label="SQLExecutionRDD [8118]<br>toJavaRDD at <unknown>:0"]; 8120 [labelType="html" label="PythonRDD [8120]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18147 { label="MicroBatchScan"; 8106 [labelType="html" label="DataSourceRDD [8106]<br>run at <unknown>:0"]; 8107 [labelType="html" label="MapPartitionsRDD [8107]<br>run at <unknown>:0"]; } subgraph cluster18146 { label="Project"; 8108 [labelType="html" label="MapPartitionsRDD [8108]<br>run at <unknown>:0"]; } subgraph cluster18142 { label="WholeStageCodegen (1)"; 8109 [labelType="html" label="MapPartitionsRDD [8109]<br>run at <unknown>:0"]; } subgraph cluster18156 { label="WholeStageCodegen (1)"; 8111 [labelType="html" label="MapPartitionsRDD [8111]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18155 { label="Filter"; 8112 [labelType="html" label="MapPartitionsRDD [8112]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18154 { label="Project"; 8113 [labelType="html" label="MapPartitionsRDD [8113]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18151 { label="WholeStageCodegen (2)"; 8114 [labelType="html" label="MapPartitionsRDD [8114]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18150 { label="Project"; 8115 [labelType="html" label="MapPartitionsRDD [8115]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18149 { label="DeserializeToObject"; 8116 [labelType="html" label="MapPartitionsRDD [8116]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18148 { label="MapPartitions"; 8117 [labelType="html" label="MapPartitionsRDD [8117]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18158 { label="mapPartitions"; 8119 [labelType="html" label="MapPartitionsRDD [8119]<br>toJavaRDD at <unknown>:0"]; } } 8106->8107; 8107->8108; 8108->8109; 8109->8110; 8110->8111; 8111->8112; 8112->8113; 8113->8114; 8114->8115; 8115->8116; 8116->8117; 8117->8118; 8118->8119; 8119->8120; }
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