3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 134 (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 / 534
Associated Job Ids:
134
DAG Visualization
digraph G { subgraph clusterstage_134 { label="Stage 134"; 1411 [labelType="html" label="SQLExecutionRDD [1411]<br>run at <unknown>:0"]; 1419 [labelType="html" label="SQLExecutionRDD [1419]<br>toJavaRDD at <unknown>:0"]; 1421 [labelType="html" label="PythonRDD [1421]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3154 { label="MicroBatchScan"; 1407 [labelType="html" label="DataSourceRDD [1407]<br>run at <unknown>:0"]; 1408 [labelType="html" label="MapPartitionsRDD [1408]<br>run at <unknown>:0"]; } subgraph cluster3153 { label="Project"; 1409 [labelType="html" label="MapPartitionsRDD [1409]<br>run at <unknown>:0"]; } subgraph cluster3149 { label="WholeStageCodegen (1)"; 1410 [labelType="html" label="MapPartitionsRDD [1410]<br>run at <unknown>:0"]; } subgraph cluster3163 { label="WholeStageCodegen (1)"; 1412 [labelType="html" label="MapPartitionsRDD [1412]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3162 { label="Filter"; 1413 [labelType="html" label="MapPartitionsRDD [1413]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3161 { label="Project"; 1414 [labelType="html" label="MapPartitionsRDD [1414]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3158 { label="WholeStageCodegen (2)"; 1415 [labelType="html" label="MapPartitionsRDD [1415]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3157 { label="Project"; 1416 [labelType="html" label="MapPartitionsRDD [1416]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3156 { label="DeserializeToObject"; 1417 [labelType="html" label="MapPartitionsRDD [1417]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3155 { label="MapPartitions"; 1418 [labelType="html" label="MapPartitionsRDD [1418]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster3165 { label="mapPartitions"; 1420 [labelType="html" label="MapPartitionsRDD [1420]<br>toJavaRDD at <unknown>:0"]; } } 1407->1408; 1408->1409; 1409->1410; 1410->1411; 1411->1412; 1412->1413; 1413->1414; 1414->1415; 1415->1416; 1416->1417; 1417->1418; 1418->1419; 1419->1420; 1420->1421; }
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