3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 807 (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 / 462
Associated Job Ids:
807
DAG Visualization
digraph G { subgraph clusterstage_807 { label="Stage 807"; 8473 [labelType="html" label="SQLExecutionRDD [8473]<br>run at <unknown>:0"]; 8481 [labelType="html" label="SQLExecutionRDD [8481]<br>toJavaRDD at <unknown>:0"]; 8483 [labelType="html" label="PythonRDD [8483]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18954 { label="MicroBatchScan"; 8469 [labelType="html" label="DataSourceRDD [8469]<br>run at <unknown>:0"]; 8470 [labelType="html" label="MapPartitionsRDD [8470]<br>run at <unknown>:0"]; } subgraph cluster18953 { label="Project"; 8471 [labelType="html" label="MapPartitionsRDD [8471]<br>run at <unknown>:0"]; } subgraph cluster18949 { label="WholeStageCodegen (1)"; 8472 [labelType="html" label="MapPartitionsRDD [8472]<br>run at <unknown>:0"]; } subgraph cluster18963 { label="WholeStageCodegen (1)"; 8474 [labelType="html" label="MapPartitionsRDD [8474]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18962 { label="Filter"; 8475 [labelType="html" label="MapPartitionsRDD [8475]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18961 { label="Project"; 8476 [labelType="html" label="MapPartitionsRDD [8476]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18958 { label="WholeStageCodegen (2)"; 8477 [labelType="html" label="MapPartitionsRDD [8477]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18957 { label="Project"; 8478 [labelType="html" label="MapPartitionsRDD [8478]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18956 { label="DeserializeToObject"; 8479 [labelType="html" label="MapPartitionsRDD [8479]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18955 { label="MapPartitions"; 8480 [labelType="html" label="MapPartitionsRDD [8480]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster18965 { label="mapPartitions"; 8482 [labelType="html" label="MapPartitionsRDD [8482]<br>toJavaRDD at <unknown>:0"]; } } 8469->8470; 8470->8471; 8471->8472; 8472->8473; 8473->8474; 8474->8475; 8475->8476; 8476->8477; 8477->8478; 8478->8479; 8479->8480; 8480->8481; 8481->8482; 8482->8483; }
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