3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 374 (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 / 464
Associated Job Ids:
374
DAG Visualization
digraph G { subgraph clusterstage_374 { label="Stage 374"; 3931 [labelType="html" label="SQLExecutionRDD [3931]<br>run at <unknown>:0"]; 3939 [labelType="html" label="SQLExecutionRDD [3939]<br>toJavaRDD at <unknown>:0"]; 3941 [labelType="html" label="PythonRDD [3941]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8794 { label="MicroBatchScan"; 3927 [labelType="html" label="DataSourceRDD [3927]<br>run at <unknown>:0"]; 3928 [labelType="html" label="MapPartitionsRDD [3928]<br>run at <unknown>:0"]; } subgraph cluster8793 { label="Project"; 3929 [labelType="html" label="MapPartitionsRDD [3929]<br>run at <unknown>:0"]; } subgraph cluster8789 { label="WholeStageCodegen (1)"; 3930 [labelType="html" label="MapPartitionsRDD [3930]<br>run at <unknown>:0"]; } subgraph cluster8803 { label="WholeStageCodegen (1)"; 3932 [labelType="html" label="MapPartitionsRDD [3932]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8802 { label="Filter"; 3933 [labelType="html" label="MapPartitionsRDD [3933]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8801 { label="Project"; 3934 [labelType="html" label="MapPartitionsRDD [3934]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8798 { label="WholeStageCodegen (2)"; 3935 [labelType="html" label="MapPartitionsRDD [3935]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8797 { label="Project"; 3936 [labelType="html" label="MapPartitionsRDD [3936]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8796 { label="DeserializeToObject"; 3937 [labelType="html" label="MapPartitionsRDD [3937]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8795 { label="MapPartitions"; 3938 [labelType="html" label="MapPartitionsRDD [3938]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster8805 { label="mapPartitions"; 3940 [labelType="html" label="MapPartitionsRDD [3940]<br>toJavaRDD at <unknown>:0"]; } } 3927->3928; 3928->3929; 3929->3930; 3930->3931; 3931->3932; 3932->3933; 3933->3934; 3934->3935; 3935->3936; 3936->3937; 3937->3938; 3938->3939; 3939->3940; 3940->3941; }
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