3.5.7
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
hdh-spark-job
application UI
Details for Stage 3026 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 ms
Locality Level Summary:
Process local: 1
Input Size / Records:
5.5 KiB / 247
Associated Job Ids:
2040
DAG Visualization
digraph G { subgraph clusterstage_3026 { label="Stage 3026"; subgraph cluster20879 { label="Scan csv "; 8962 [labelType="html" label="FileScanRDD [8962]<br>count at CreateSubscriptionService.java:123"]; 8963 [labelType="html" label="MapPartitionsRDD [8963]<br>count at CreateSubscriptionService.java:123"]; } subgraph cluster20876 { label="WholeStageCodegen (1)"; 8964 [labelType="html" label="MapPartitionsRDD [8964]<br>count at CreateSubscriptionService.java:123"]; } subgraph cluster20880 { label="mapPartitionsInternal"; 8965 [labelType="html" label="MapPartitionsRDD [8965]<br>count at CreateSubscriptionService.java:123"]; } subgraph cluster20881 { label="mapPartitionsInternal"; 8966 [labelType="html" label="*(1) Project [Pays#339770 AS 04F95267_1705_42D1_B45F_796778D83A05#339847, ISO 3166-1 alpha-2#339771 AS B7BA1423_058A_4625_862B_CF74655E19FB#339848, ISO 3166-1 alpha-3#339772 AS FD478E7F_8CFD_46D4_8174_9A79B486E028#339849, ISO 3166-1 num\u00E9rique#339773 AS 03DF3B94_AF38_46D7_A925_98AD85C3B15D#339850]\n+- FileScan csv [Pays#339770,ISO 3166-1 alpha-2#339771,ISO 3166-1 alpha-3#339772,ISO 3166-1 num\u00E9rique#339773] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/515F75A7_03A7_461A_9E59_052C6B70C..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Pays:string,ISO 3166-1 alpha-2:string,ISO 3166-1 alpha-3:string,ISO 3166-1 num\u00E9rique:string>\n [8966] [Cached]<br>count at CreateSubscriptionService.java:123"]; } } 8962->8963; 8963->8964; 8964->8965; 8965->8966; }
8966
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