3.5.8
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
processing-stream-kafka-raw-to-m...
application UI
Details for Stage 84 (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 / 423
Associated Job Ids:
84
DAG Visualization
digraph G { subgraph clusterstage_84 { label="Stage 84"; 886 [labelType="html" label="SQLExecutionRDD [886]<br>run at <unknown>:0"]; 894 [labelType="html" label="SQLExecutionRDD [894]<br>toJavaRDD at <unknown>:0"]; 896 [labelType="html" label="PythonRDD [896]<br>call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1979 { label="MicroBatchScan"; 882 [labelType="html" label="DataSourceRDD [882]<br>run at <unknown>:0"]; 883 [labelType="html" label="MapPartitionsRDD [883]<br>run at <unknown>:0"]; } subgraph cluster1978 { label="Project"; 884 [labelType="html" label="MapPartitionsRDD [884]<br>run at <unknown>:0"]; } subgraph cluster1974 { label="WholeStageCodegen (1)"; 885 [labelType="html" label="MapPartitionsRDD [885]<br>run at <unknown>:0"]; } subgraph cluster1988 { label="WholeStageCodegen (1)"; 887 [labelType="html" label="MapPartitionsRDD [887]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1987 { label="Filter"; 888 [labelType="html" label="MapPartitionsRDD [888]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1986 { label="Project"; 889 [labelType="html" label="MapPartitionsRDD [889]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1983 { label="WholeStageCodegen (2)"; 890 [labelType="html" label="MapPartitionsRDD [890]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1982 { label="Project"; 891 [labelType="html" label="MapPartitionsRDD [891]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1981 { label="DeserializeToObject"; 892 [labelType="html" label="MapPartitionsRDD [892]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1980 { label="MapPartitions"; 893 [labelType="html" label="MapPartitionsRDD [893]<br>toJavaRDD at <unknown>:0"]; } subgraph cluster1990 { label="mapPartitions"; 895 [labelType="html" label="MapPartitionsRDD [895]<br>toJavaRDD at <unknown>:0"]; } } 882->883; 883->884; 884->885; 885->886; 886->887; 887->888; 888->889; 889->890; 890->891; 891->892; 892->893; 893->894; 894->895; 895->896; }
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