5.DataNode工作机制、数据完整性、数据结点服役退役

news/2024/5/20 3:09:24 标签: hadoop, hdfs

本文目录如下:

  • 第9章 DataNode(面试开发重点)
    • 9.1 DataNode工作机制
    • 9.2 数据完整性
    • 9.3 掉线时限参数设置
    • 9.4 服役新数据节点
      • 9.4.1 环境准备
      • 9.4.2 服役新节点具体步骤
    • 9.5 退役旧数据节点
      • 9.5.1 添加白名单
      • 9.5.2 如果数据不均衡,可以用命令实现集群的再平衡
      • 9.5.3 黑名单退役
    • 9.6 Datanode多目录配置

第9章 DataNode(面试开发重点)

9.1 DataNode工作机制

DataNode工作机制,如图3-15所示。
图3-15  DataNode工作机制

  • 1)一个数据块在DataNode上以文件形式存储在磁盘上,包括两个文件,一个是数据本身,一个是元数据包括数据块的长度,块数据的校验和,以及时间戳。
  • 2)DataNode启动后向NameNode注册,通过后,周期性(1小时)的向NameNode上报所有的块信息。
  • 3)心跳是每3秒一次,心跳返回结果带有NameNode给该DataNode的命令如复制块数据到另一台机器,或删除某个数据块。如果超过10分钟没有收到某个DataNode的心跳,则认为该节点不可用。
  • 4)集群运行中可以安全加入和退出一些机器。

9.2 数据完整性

思考:如果电脑磁盘里面存储的数据是控制高铁信号灯的红灯信号(1)和绿灯信号(0),但是存储该数据的磁盘坏了,一直显示是绿灯,是否很危险?同理DataNode节点上的数据损坏了,却没有发现,是否也很危险,那么如何解决呢?
如下是DataNode节点保证数据完整性的方法。

  • 1)当DataNode读取Block的时候,它会计算CheckSum。
  • 2)如果计算后的CheckSum,与Block创建时值不一样,说明Block已经损坏。
  • 3)Client读取其他DataNode上的Block。
  • 4)DataNode在其文件创建后周期验证CheckSum,如图3-16所示。
    在这里插入图片描述

图3-16  校验和

9.3 掉线时限参数设置

在这里插入图片描述

需要注意的是hdfs-site.xml 配置文件中的heartbeat.recheck.interval的单位为毫秒,dfs.heartbeat.interval的单位为

<property>
    <name>dfs.namenode.heartbeat.recheck-interval</name>
    <value>300000</value>
</property>
<property>
    <name>dfs.heartbeat.interval</name>
    <value>3</value>
</property>

9.4 服役新数据节点

需求:随着公司业务的增长,数据量越来越大,原有的数据节点的容量已经不能满足存储数据的需求,需要在原有集群基础上动态添加新的数据节点。

9.4.1 环境准备

(1)在hadoop102主机上再克隆一台hadoop103主机
(2)修改IP地址和主机名称
(3)删除原来HDFS文件系统留存的文件(/opt/module/hadoop-2.7.2/datalogs
(4)为新机同步Hadoop环境Jdk环境环境变量(/etc/profile)
(5)source一下配置文件
注:具体详细步骤可以参考:环境搭建传送门

9.4.2 服役新节点具体步骤

  • (1) 直接启动DataNode,即可关联到集群
[xqzhao@hadoop103 hadoop-2.7.2]$ sbin/hadoop-daemon.sh start datanode
[xqzhao@hadoop103 hadoop-2.7.2]$ sbin/yarn-daemon.sh start nodemanager

在这里插入图片描述

  • (2) 在hadoop105上上传文件
[xqzhao@hadoop103 hadoop-2.7.2]$ hadoop fs -put /opt/module/hadoop-2.7.2/LICENSE.txt /
  • (3) 如果数据不均衡,可以用命令实现集群的再平衡
[atguigu@hadoop100 sbin]$ ./start-balancer.sh
starting balancer, logging to /opt/module/hadoop-2.7.2/logs/hadoop-atguigu-balancer-hadoop102.out
Time Stamp               Iteration#  Bytes Already Moved  Bytes Left To Move  Bytes Being Moved

9.5 退役旧数据节点

实现退役建议使用黑名单机制,处理的更加温柔。

9.5.1 添加白名单

添加到白名单的主机节点,都允许访问NameNode,不在白名单的主机节点,都会被退出。

配置白名单的具体步骤如下:

  • (1) 在NameNode的/opt/module/hadoop-2.7.2/etc/hadoop目录下创建dfs.hosts文件
[xqzhao@hadoop100 hadoop]$ pwd
/opt/module/hadoop-2.7.2/etc/hadoop
[xqzhao@hadoop100 hadoop]$ touch dfs.hosts
[xqzhao@hadoop100 hadoop]$ vim dfs.hosts

添加如下主机名称(不添加hadoop105)
hadoop100
hadoop101
hadoop102
  • (2) 在NameNode的hdfs-site.xml配置文件中增加dfs.hosts属性
<property>
	<name>dfs.hosts</name>
	<value>/opt/module/hadoop-2.7.2/etc/hadoop/dfs.hosts</value>
</property>
  • (3) 配置文件分发
[xqzhao@hadoop100 hadoop]$ xsync hdfs-site.xml
  • (4) 刷新NameNode
[xqzhao@hadoop100 hadoop-2.7.2]$ hdfs dfsadmin -refreshNodes
Refresh nodes successful
  • (5) 更新ResourceManager节点
[xqzhao@hadoop100 hadoop-2.7.2]$ yarn rmadmin -refreshNodes
17/06/24 14:17:11 INFO client.RMProxy: Connecting to ResourceManager at hadoop103/192.168.1.103:8033
  • (6) 在web浏览器上查看
    在这里插入图片描述

9.5.2 如果数据不均衡,可以用命令实现集群的再平衡

[xqzhao@hadoop100 sbin]$ ./start-balancer.sh
starting balancer, logging to /opt/module/hadoop-2.7.2/logs/hadoop-atguigu-balancer-hadoop102.out
Time Stamp               Iteration#  Bytes Already Moved  Bytes Left To Move  Bytes Being Moved

9.5.3 黑名单退役

在黑名单上面的主机都会被强制退出。

  • (1) 在NameNode的/opt/module/hadoop-2.7.2/etc/hadoop目录下创建blacklist文件
[xqzhao@hadoop100 hadoop]$ pwd
/opt/module/hadoop-2.7.2/etc/hadoop

[xqzhao@hadoop100 hadoop]$ touch blacklist
[xqzhao@hadoop100 hadoop]$ vim blacklist

添加如下主机名称(要退役的节点)
hadoop105
  • (2) 在NameNode的hdfs-site.xml配置文件中增加dfs.hosts.exclude属性
<property>
	<name>dfs.hosts.exclude</name>
    <value>/opt/module/hadoop-2.7.2/etc/hadoop/blacklist</value>
</property>
  • (3) 刷新NameNode、刷新ResourceManager
[xqzhao@hadoop100 hadoop-2.7.2]$ hdfs dfsadmin -refreshNodes
Refresh nodes successful

[xqzhao@hadoop100 hadoop-2.7.2]$ yarn rmadmin -refreshNodes

17/06/24 14:55:56 INFO client.RMProxy: Connecting to ResourceManager at hadoop103/192.168.1.103:8033
  • (4) 检查Web浏览器,退役节点的状态为decommission in progress(退役中),说明数据节点正在复制块到其他节点,如图3-17所示
    图3-17  退役中
  • (5) 等待退役节点状态为decommissioned(所有块已经复制完成),停止该节点及节点资源管理器。注意:如果副本数是3,服役的节点小于等于3,是不能退役成功的,需要修改副本数后才能退役,如图3-18所示
    图3-18 已退役
[xqzhao@hadoop103 hadoop-2.7.2]$ sbin/hadoop-daemon.sh stop datanode
stopping datanode
[xqzhao@hadoop103 hadoop-2.7.2]$ sbin/yarn-daemon.sh stop nodemanager
stopping nodemanager
  • (6) 如果数据不均衡,可以用命令实现集群的再平衡
[xqzhao@hadoop100 hadoop-2.7.2]$ sbin/start-balancer.sh 
starting balancer, logging to /opt/module/hadoop-2.7.2/logs/hadoop-xqzhao-balancer-hadoop100.out
Time Stamp               Iteration#  Bytes Already Moved  Bytes Left To Move  Bytes Being Moved

注意:不允许白名单和黑名单中同时出现同一个主机名称。

9.6 Datanode多目录配置

  • (1) DataNode也可以配置成多个目录,每个目录存储的数据不一样。即:数据不是副本
  • (2) 具体配置如下
    hdfs-site.xml
<property>
    <name>dfs.datanode.data.dir</name>
	<value>file:///${hadoop.tmp.dir}/dfs/data1,file:///${hadoop.tmp.dir}/dfs/data2</value>
</property>

声明:本文是学习时记录的笔记,如有侵权请告知删除!
原视频地址:https://www.bilibili.com/video/BV1Me411W7PV


http://www.niftyadmin.cn/n/1743766.html

相关文章

1.MapReduce入门-MapReduce进程、常用序列化类型、WordCount实例

本文目录如下&#xff1a;第1章 MapReduce概述1.1 MapReduce进程1.2 常用数据序列化类型1.3 MapReduce编程规范1.3.1 Mapper阶段1.3.2 Reducer阶段1.3.3 Driver阶段1.4 WordCount实例1.4.1 创建一个Maven工程MapReduce-0100-WordCount1.4.2 导入相应依赖1.4.3 配置日志信息1.4.…

2.MapReduce序列化—实现序列化接口、序列化案例实战

本文目录如下&#xff1a;第二章 MapReduce序列化案例2.1 自定义FloBean对象实现序列化接口&#xff08;Writable&#xff09;2.2 序列化案例实操2.3.1 需求2.3.2 需求分析2.3.3 编写MapReduce程序第二章 MapReduce序列化案例 2.1 自定义FloBean对象实现序列化接口&#xff08…

1.Scala基础—数据类型、标准输入、类和对象、分支循环、函数、匿名函数、高阶函数

本文目录如下&#xff1a;第一章 Scala基础1.0 前言1.1 数据类型1.2 Hello World1.2 键盘标准输入1.3 类和对象、伴生类和伴生对象1.4 分支循环1.4.1 if else1.4.2 for,while,do...while1.5 函数1.5.1 Scala函数的定义1.5.2 包含参数默认值的函数1.5.3 可变参数个数的函数1.6 匿…

2.Scala基础—字符串、数组、二维数组、Scala常用Array函数

本文目录如下&#xff1a;第二章 Scala字符串2.1 String2.2 StringBuilder可变2.3 String操作方法举例第三章 数组3.1 创建数组3.2 Scala常用Array函数第二章 Scala字符串 2.1 String 2.2 StringBuilder可变 2.3 String操作方法举例 比较: equals比较忽略大小写: equalslgn…

3.Scala基础—集合(List、Set、Map、元组Tuple)

本文目录如下&#xff1a;第四章 集合4.1 List4.1.1 创建list4.1.2 list遍历4.1.3 list方法举例4.2 Set4.2.1 创建Set4.2.2 遍历Set4.2.3 Set方法举例4.3 Map4.3.1 创建Map4.3.2 获取Map的值4.3.3 遍历Map4.3.4 合并Map4.3.5 Map方法举例4.3.6 可变长度Map4.4 元组Tuple4.4.1. …

4.Scala基础—Trait (特质)、模式匹配、偏函数 Collect

本文目录如下&#xff1a;第五章 Trait (特质)5.1 概念5.2 具体写法5.2.1.trait中带属性带方法实现第六章 模式匹配6.1 概念6.2 具体写法6.3 注意点第七章 偏函数(Collect)第五章 Trait (特质) 5.1 概念 Scala中Trait(特质)相当于Java的接口&#xff0c;实际上它比接口还功能…

5.Scala基础—样例类、隐式转换、Actor Model

本文目录如下&#xff1a;第八章 样例类&#xff08;Case Classes&#xff09;8.1 概念8.2 具体写法第九章 隐式转换&#xff08;重要&#xff09;9.1 概念9.2 隐式值与隐式参数9.2.1 注意点9.2.2 具体方法9.3 隐式转换函数9.3.1 注意点9.3.2 具体写法9.4 隐式类9.4.1 注意点9.…

1.Spark基础—核心模块、快速上手、WordCount案例开发、部署模式对比、端口号汇总

本文目录如下&#xff1a;前言 Spark核心模块第1章 Spark快速上手1.1 安装环境变量1.2 创建Maven项目1.2.1 增加Scala组件1.2.2 增加依赖关系1.3 编写WordCount代码1.4 部署模式对比1.5 端口号前言 Spark核心模块 Spark是一种基于内存的快速、通用、可扩展的大数据分析计算引擎…