3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 1001 (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 / 414
Associated Job Ids:
1002
DAG Visualization
digraph G { subgraph clusterstage_1001 { label="Stage 1001"; 10526 [labelType="html" label="SQLExecutionRDD [10526]<br>run at <unknown>:0"]; 10534 [labelType="html" label="SQLExecutionRDD [10534]<br>toJavaRDD at <unknown>:0"]; 10536 [labelType="html" label="PythonRDD [10536]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23548 { label="MicroBatchScan"; 10522 [labelType="html" label="DataSourceRDD [10522]<br>run at <unknown>:0"]; 10523 [labelType="html" label="MapPartitionsRDD [10523]<br>run at <unknown>:0"]; } subgraph cluster23547 { label="Project"; 10524 [labelType="html" label="MapPartitionsRDD [10524]<br>run at <unknown>:0"]; } subgraph cluster23543 { label="WholeStageCodegen (1)"; 10525 [labelType="html" label="MapPartitionsRDD [10525]<br>run at <unknown>:0"]; } subgraph cluster23557 { label="WholeStageCodegen (1)"; 10527 [labelType="html" label="MapPartitionsRDD [10527]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23556 { label="Filter"; 10528 [labelType="html" label="MapPartitionsRDD [10528]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23555 { label="Project"; 10529 [labelType="html" label="MapPartitionsRDD [10529]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23552 { label="WholeStageCodegen (2)"; 10530 [labelType="html" label="MapPartitionsRDD [10530]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23551 { label="Project"; 10531 [labelType="html" label="MapPartitionsRDD [10531]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23550 { label="DeserializeToObject"; 10532 [labelType="html" label="MapPartitionsRDD [10532]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23549 { label="MapPartitions"; 10533 [labelType="html" label="MapPartitionsRDD [10533]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster23559 { label="mapPartitions"; 10535 [labelType="html" label="MapPartitionsRDD [10535]<br>toJavaRDD at <unknown>:0"]; } } 10522->10523; 10523->10524; 10524->10525; 10525->10526; 10526->10527; 10527->10528; 10528->10529; 10529->10530; 10530->10531; 10531->10532; 10532->10533; 10533->10534; 10534->10535; 10535->10536; }
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