大数据集群二次开发及调优使用指导(一)-HDFS

南墨10个月前技术文章219

1.   典型业务调优

涉及HDFS的相关业务一般可以分为IO密集型业务,计算密集型业务,低延迟业务,高吞吐量业务

1.1     低延迟业务

计算密集型业务,低延迟业务,这一类业务通常是对大量NameNode文件目录访问为主的(权限判断,文件存在性,文件信息查询等对NameNode元数据操作为主的)。因此需要针对NameNode的处理能力进行调整。主要可以采取以下措施:

l  通过新增NameNode引入Federation的方案实现,将高优先级的业务部署在单独的NameNode,以解决资源使用的问题。

l  在业务高峰期间,关闭HDFS的审计日志级别和运行日志级别修改为WARN级别。在业务降低的时候可以再开启INFO级别。

l  硬件能力提升:

提升NameNode节点的CPU主频。

更换DataNode的磁盘为高性能磁盘或者SSD

l  减少网络带宽延迟。

1.2     高吞吐量业

高吞吐量业务,这一类业务主要是大文件操作,对DataNodeIO需求更高。主要可以采取以下措施:

l  扩容DataNode节点数量。提高集群的吞吐量。

l  扩容DataNode节点的磁盘数量,以提高单DataNodeI/O能力。

l  更换DataNode挂载的磁盘类型,使用更高性能的磁盘或者SSD

1.3     实时数据

实时数据需要HDFS能尽快响应业务请求,对节点性能有较高的要求。为保证业务实时性,一般采用配置高性能的节点,并将业务隔离的方案。主要可以采取以下措施:

l  采用分级存储,将存储节点按性能分组,由高性能节点为其提供业务。

l  数据节点采用SSD存储介质。

l  采用Federation特性,隔离NameNode以及数据节点。

1.4     频繁访问数据

频繁访问的数据一般指写入完成后,需要重复读取,偶尔有修改变化的数据。

对于这一类数据,主要可以采取以下措施:

l  使用Central Cache特性,将对应的文件缓存到内存。(在节点宕机时存在数据丢失风险)

l  使用分级存储特性,将对应文件存储到SSD介质。

1.5     临时数据

临时数据一般是指在写入完成后,立即进行业务处理,处理完成后删除的数据。

对于这一类数据,主要可以采取以下措施:

l  使用分级存储,将数据分布存储到RAM盘。

l  将副本数设置为2个,减少系统存储、网络压力。

1.6     归档数据

归档数据是指数据存储到集群后,一段时间不再访问的数据:

对于这一类数据,主要可以采取以下措施:

l  可以设置冷数据归档目录为I/O性能较慢的存储介质上,也可以减少副本数等。

l  存储数据时,采用HAR格式存储。

l  使用分级存储特性,将这些数据存储到低性能节点上。

2.   二次开发业务应用指导

HDFS的数据导入,读取当前大部分是通过上层组件Flume HBase sqoop等实现的

也有部分的HDFS的二次开发针对读写的处理。

应用的客户端应用开发处理通常是采用分布式框架(如MRTez 部署在各节点运行。如果部署在集群外或者部署在单节点上,分布在不同节点的客户端上,避免单节点的客户端网络IO或者磁盘IO成为瓶颈。

针对HDFS的具体应用开发有一些常用的API可以提升处理能力。

2.1     使用预读取能力

HDFS在数据读取时,提供预读取接口,对于连续读取的情况,可以使用预读取能力,提升业务吞吐量。

FSDataInputStream.setReadahead (Long readahead)

FSDataInputStream.setDropBehind (Boolean dropBehind)

2.2     计算数据就近原则

HDFS提供了短路读short-circuit特性,如果客户端和数据在同样的节点上,将能有效提升读写性能。

l  数据写入时,指定优先写入的节点

HDFS客户端在创建文件时,支持指定DataNode存储节点的参数,客户端在数据写入时,可以指定数据写入的优选节点。

l  数据读取时,将计算下发到数据所在的节点

HDFS客户端提供了API,可以获取文件存储的节点位置,数据读取时,应尽量将计算下发到数据所在节点。

2.3     避免小文件存储

HDFS在设计时,主要用于存储海量的大文件。这里大文件定义指,每个文件体积应该大于128MB

如果需要存储小文件,应该使用HAR文件接口。

HAR文件接口:

HAR格式是HADOOP中的归档文件格式,其原理是将多个小文件打包到一个HDFS文件中。其读写是,需要用归档格式的API


相关文章

HDFS Fsimage分析磁盘目录(文件级别)

HDFS Fsimage分析磁盘目录(文件级别)

首先获取fsimage信息hdfs dfsadmin -fetchImage  /opt/fsimage格式化fsimage 转换为可读文本hdfs oiv -i /opt/fsimage/fsima...

MySQL优化器特性(八)索引范围扫描成本计算

MySQL优化器特性(八)索引范围扫描成本计算

range执行计划中的range表示索引范围扫描。索引范围扫描的执行过程大致如下:1、根据where条件中索引字段的条件,定位到索引结构中的第一条满足条件的记录。2、根据索引中记录的rowid,到表中...

MySQL Group Replication(一)部署篇

MySQL Group Replication(一)部署篇

MGR 简介Group Replication 是 MySQL 在 2016 年 12 月以 GA 的形式发布,以插件的形式绑定在 MySQL 服务器上。传统的 MySQL 复制功能是异步复制,而 M...

Doris 介绍及使用场景

Doris 介绍及使用场景

Doris 介绍                    Apache Doris 是一个基于 MPP 架构的高性能、实时的分析型数据库,以极速易用的特点被人们所熟知,仅需亚秒级响应时间即可返回海量数据...

Go 链表的实现

Go 链表的实现

链表是一种物理存储单元上非连续、非顺序的存储结构,数据元素的逻辑顺序是通过链表中的指针链接次序实现的。链表由一系列结点(链表中每一个元素称为结点)组成,结点可以在运行时动态生成。每个结点包括两个部分:...

trino组件对接alluxio(三)

trino组件对接alluxio(三)

本文是基于已经部署了trino和alluxio的基础上,进行的trino与alluxio的组件对接,alluxio已经开启了高可用模式。安装部署1、增加alluxio配置在core-site.xml和...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。