3.5.7
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
hdh-spark-job
application UI
Details for Stage 1160 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.8 s
Locality Level Summary:
Process local: 1
Input Size / Records:
729.7 KiB / 34851
Output Size / Records:
0.0 B / 34851
Associated Job Ids:
885
DAG Visualization
digraph G { subgraph clusterstage_1160 { label="Stage 1160"; 3549 [labelType="html" label="SQLExecutionRDD [3549]<br>toJavaRDD at AbsExportExecutor.java:55"]; 3554 [labelType="html" label="SQLExecutionRDD [3554]<br>jdbc at SqlDbWriter.java:111"]; subgraph cluster8470 { label="Scan parquet "; 3545 [labelType="html" label="FileScanRDD [3545]<br>toJavaRDD at AbsExportExecutor.java:55"]; 3546 [labelType="html" label="MapPartitionsRDD [3546]<br>toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster8466 { label="WholeStageCodegen (1)"; 3547 [labelType="html" label="MapPartitionsRDD [3547]<br>toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster8465 { label="DeserializeToObject"; 3548 [labelType="html" label="MapPartitionsRDD [3548]<br>toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster8471 { label="mapPartitions"; 3550 [labelType="html" label="MapPartitionsRDD [3550]<br>toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster8472 { label="map"; 3551 [labelType="html" label="MapPartitionsRDD [3551]<br>createDataFrame at AbsExportExecutor.java:55"]; } subgraph cluster8474 { label="WholeStageCodegen (1)"; 3552 [labelType="html" label="MapPartitionsRDD [3552]<br>jdbc at SqlDbWriter.java:111"]; } subgraph cluster8473 { label="DeserializeToObject"; 3553 [labelType="html" label="MapPartitionsRDD [3553]<br>jdbc at SqlDbWriter.java:111"]; } subgraph cluster8477 { label="mapPartitions"; 3555 [labelType="html" label="MapPartitionsRDD [3555]<br>jdbc at SqlDbWriter.java:111"]; } } 3545->3546; 3546->3547; 3547->3548; 3548->3549; 3549->3550; 3550->3551; 3551->3552; 3552->3553; 3553->3554; 3554->3555; }
Event Timeline
Enable zooming
Tasks: 1. 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