3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 178 (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 / 421
Associated Job Ids:
178
DAG Visualization
digraph G { subgraph clusterstage_178 { label="Stage 178"; 1873 [labelType="html" label="SQLExecutionRDD [1873]<br>run at <unknown>:0"]; 1881 [labelType="html" label="SQLExecutionRDD [1881]<br>toJavaRDD at <unknown>:0"]; 1883 [labelType="html" label="PythonRDD [1883]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster4188 { label="MicroBatchScan"; 1869 [labelType="html" label="DataSourceRDD [1869]<br>run at <unknown>:0"]; 1870 [labelType="html" label="MapPartitionsRDD [1870]<br>run at <unknown>:0"]; } subgraph cluster4187 { label="Project"; 1871 [labelType="html" label="MapPartitionsRDD [1871]<br>run at <unknown>:0"]; } subgraph cluster4183 { label="WholeStageCodegen (1)"; 1872 [labelType="html" label="MapPartitionsRDD [1872]<br>run at <unknown>:0"]; } subgraph cluster4197 { label="WholeStageCodegen (1)"; 1874 [labelType="html" label="MapPartitionsRDD [1874]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4196 { label="Filter"; 1875 [labelType="html" label="MapPartitionsRDD [1875]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4195 { label="Project"; 1876 [labelType="html" label="MapPartitionsRDD [1876]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4192 { label="WholeStageCodegen (2)"; 1877 [labelType="html" label="MapPartitionsRDD [1877]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4191 { label="Project"; 1878 [labelType="html" label="MapPartitionsRDD [1878]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4190 { label="DeserializeToObject"; 1879 [labelType="html" label="MapPartitionsRDD [1879]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4189 { label="MapPartitions"; 1880 [labelType="html" label="MapPartitionsRDD [1880]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster4199 { label="mapPartitions"; 1882 [labelType="html" label="MapPartitionsRDD [1882]<br>toJavaRDD at <unknown>:0"]; } } 1869->1870; 1870->1871; 1871->1872; 1872->1873; 1873->1874; 1874->1875; 1875->1876; 1876->1877; 1877->1878; 1878->1879; 1879->1880; 1880->1881; 1881->1882; 1882->1883; }
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