3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 769 (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 / 502
Associated Job Ids:
769
DAG Visualization
digraph G { subgraph clusterstage_769 { label="Stage 769"; 8074 [labelType="html" label="SQLExecutionRDD [8074]<br>run at <unknown>:0"]; 8082 [labelType="html" label="SQLExecutionRDD [8082]<br>toJavaRDD at <unknown>:0"]; 8084 [labelType="html" label="PythonRDD [8084]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18061 { label="MicroBatchScan"; 8070 [labelType="html" label="DataSourceRDD [8070]<br>run at <unknown>:0"]; 8071 [labelType="html" label="MapPartitionsRDD [8071]<br>run at <unknown>:0"]; } subgraph cluster18060 { label="Project"; 8072 [labelType="html" label="MapPartitionsRDD [8072]<br>run at <unknown>:0"]; } subgraph cluster18056 { label="WholeStageCodegen (1)"; 8073 [labelType="html" label="MapPartitionsRDD [8073]<br>run at <unknown>:0"]; } subgraph cluster18070 { label="WholeStageCodegen (1)"; 8075 [labelType="html" label="MapPartitionsRDD [8075]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18069 { label="Filter"; 8076 [labelType="html" label="MapPartitionsRDD [8076]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18068 { label="Project"; 8077 [labelType="html" label="MapPartitionsRDD [8077]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18065 { label="WholeStageCodegen (2)"; 8078 [labelType="html" label="MapPartitionsRDD [8078]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18064 { label="Project"; 8079 [labelType="html" label="MapPartitionsRDD [8079]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18063 { label="DeserializeToObject"; 8080 [labelType="html" label="MapPartitionsRDD [8080]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18062 { label="MapPartitions"; 8081 [labelType="html" label="MapPartitionsRDD [8081]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18072 { label="mapPartitions"; 8083 [labelType="html" label="MapPartitionsRDD [8083]<br>toJavaRDD at <unknown>:0"]; } } 8070->8071; 8071->8072; 8072->8073; 8073->8074; 8074->8075; 8075->8076; 8076->8077; 8077->8078; 8078->8079; 8079->8080; 8080->8081; 8081->8082; 8082->8083; 8083->8084; }
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