当前位置： 首页 > news >正文

HBase跨版本数据迁移总结

news 来源：原创 2024/5/19 3:33:51

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

版权声明：本文由王亮原创文章，转载请注明出处: 
文章原文链接：https://www.qcloud.com/community/article/115

来源：腾云阁 https://www.qcloud.com/community

 

某客户大数据测试场景为：Solr类似画像的数据查出用户标签——通过这些标签在HBase查询详细信息。以上测试功能以及性能。
其中HBase的数据量为500G，Solr约5T。数据均需要从对方的集群人工迁移到我们自己搭建的集群。由于Solr没有在我们集群中集成，优先开始做HBase的数据迁移，以下总结了HBase使用以及数据迁移遇到的各种问题以及解决方法。

一.迁移过程遇到问题以及解决

客户HBase版本：Version 0.94.15
腾讯大数据套件HBase版本：Version 1.2.1
客户私有云系统版本（测试）：tlinux1.2
遇到的问题以及解决过程如下：

1.HBase运行异常现象一（date和hwclock）

HBase运行偶发不正常，出现组件停止运行的情况，看日志有说时间的差异等信息，但date查看完全一致，想到可能是硬件时间的差异问题，通过hwclock看，确实差异很大，通过hwclock -w调整后基本恢复。后确认初始化脚本中只对腾讯云环境的机器做了硬件时间同步，目前已优化。

2.HBase运行异常现象二（hostname 和/etc/resolv.conf）

HBase再次运行不正常，出现组件停止运行的情况。通过日志看如下错误
ERROR [regionserver//10.0.0.106:16020] regionserver.HRegionServer: Master passed us a different hostname to use; was=10.0.0.106, but now=host-10-0-0-106.openstacklocal
通过hostname看所有机器hostname均为内网IP，猜想可能是网络交互的时候查询什么表导致出现的不一致，查看dns解析信息如下

[root@10 ~]# hostname
10.0.0.106
; generated by /sbin/dhclient-script
#search openstacklocal 0.0.106
#nameserver 10.0.0.2
#nameserver 10.0.0.3

有search openstacklocal的情况，猜测是虚拟机的异常行为，注释掉resolv.conf里相关search信息，停掉nscd服务后，重启HBase，再未出现这个错误，HBase运行完全正常。

3.需要支持snappy的发现与修复过程：

  • 迁移表的过程中计划使用官方的import/export工具进行，第一步需要在目标集群建表，通过desc信息在目标集群建表完成后，list可看到表，通过scan查询后，无法查询内容，查日志有如下错误：
    org.apache.hadoop.HBase.DoNotRetryIOException: Compression algorithm 'snappy' previously failed test.
    通过google查询需要HBase支持snappy压缩算法，通过hadoop checknative发现集群默认确实不支持snappy算法（虽然安装snappyrpm）

    Native library checking:
hadoop:  true /data/tbds-base/usr/hdp/2.2.0.0-2041/hadoop/lib/native/libhadoop.so
zlib:    true /lib64/libz.so.1
snappy:  false
lz4:     true revision:99
bzip2:   false
openssl: false build does not support openssl.

  • 通过手动建表的方法用以下desc信息建表后可以list查看到表信息。scan无法查看表内容，日志发现如下错误
    desc信息：

    COLUMN FAMILIES DESCRIPTION                                                                 
{NAME => 'A', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TTL => 'FOR
EVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', METADATA => {'ENCODE_ON_DISK' => 'true'}}                       
{NAME => 'D', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '2147483647', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TT
L => 'FOREVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', ENCODE_ON_DISK => 'true'}

    错误信息：

    org.apache.hadoop.HBase.DoNotRetryIOException: java.lang.RuntimeException: native snappy library not available: this version of libhadoop was built without snappy support

  • 在HBase-site.xml增加属性HBase.regionserver.codecs value为snappy即可，在测试集群通过该方法，HBase启动失败

  • 后确认tlinux1.2的hadoop集群上支持snappy的方法：即需要在特定系统编译hadoop相关本地库（native库）替换hadoop当前的native库，然后HBase的启动环境脚本增加hadoop主目录即可

  • 目前tlinux1.2下的hadoop的nativesnappy库有现网使用，同时需要保证这个hadoop的库可以引用到libjvm.so（jre的一个so文件）直接替换hadoop/lib下的native目录，保证已经安装snappy的rpm包，在HBase-env.sh里添加HADOOP_HOME={Hadoop安装主目录}。再hadoop checknative后发现已支持snappy。逐步全量重启HBase。

    Native library checking:
hadoop:  true /data/tbds-base/usr/hdp/2.2.0.0-2041/hadoop/lib/native/libhadoop.so
zlib:    true /lib64/libz.so.1
snappy:  true /usr/lib64/libsnappy.so.1
lz4:     true revision:99
bzip2:   false
openssl: false build does not support openssl.

4.HBase0.9.4集群数据表到HBase1.2.1集群数据表的迁移方法

暴力迁移参考http://my.oschina.net/CainGao/blog/616502
1)找到源集群源表在hdfs上的目录位置，直接将该目录移动到目标集群HBase的表在目标集群hdfs上的表根目录下

2)暴力迁移时tableinfo信息是一个文件即.tableinfo.00000001。0.9.4的版本这个文件位于HBase表在hdfs上表目录的根目录下，而1.2.1的这个文件位于HBase表在hdfs上表目录的根目录下的./tabledesc目录下，需要手动创建这个目录并调整这个文件的位置

3) 修改复制过来的表目录文件的属主信息

4) 重启HBase的所有组件

5) 此时登录HBaseshell已经可以通过list查看到迁移过来的表，但scan等操作会失败

6) 通过HBase hbck -fixMeta修复meta信息；HBase hbck -fixAssignments 修复分区。这两个步骤的操作过程中注意观察日志是否有异常，实践中首次尝试此方法有大量错误，发现错误内容为snappy相关，支持snappy后，查看表信息，表内容正常，随机选取表内容对比也正常，可认为此种方法迁移成功。

7) 通过import/export的方法迁移时需要在目标集群手动创建目标表，查看源集群的表结构如下：
import/export参考地址

COLUMN FAMILIES DESCRIPTION                                                                  {NAME => 'A', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TTL => 'FOR
EVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', METADATA => {'ENCODE_ON_DISK' => 'true'}}                       
{NAME => 'D', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '2147483647', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TT
L => 'FOREVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', ENCODE_ON_DISK => 'true'}

通过该desc信息创建新表时出现如下错误：
Unknown argument ignored for column family A: ENCODE_ON_DISK
手动测试只要加这个参数ENCODE_ON_DISK去建表一定会出现这个错误，建表会成功，但表信息里没有这个字段了。经过look查代码发现这个字段在新版本已经废弃，但客户的老集群是版本需要这个字段，通过import的方法无法正常写入、通过步骤6）的暴力迁移成功后（暴力迁移成功兼容了这个字段），查看表的desc信息如下：

COLUMN FAMILIES DESCRIPTION                                                                  {NAME => 'A', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TTL => 'FOR
EVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', METADATA => {'ENCODE_ON_DISK' => 'true'}}                       
{NAME => 'D', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '2147483647', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TT
L => 'FOREVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', METADATA => {'ENCODE_ON_DISK' => 'true'}}

老集群表结构

COLUMN FAMILIES DESCRIPTION                                                                 {NAME => 'A', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TTL => 'FOR
EVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', METADATA => {'ENCODE_ON_DISK' => 'true'}}                       
{NAME => 'D', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSIONS => '2147483647', COMPRESSION => 'SNAPPY', MIN_VERSIONS => '0', TT
L => 'FOREVER', KEEP_DELETED_CELLS => 'false', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true', ENCODE_ON_DISK => 'true'}

可以看到关于ENCODE_ON_DISK字段在新老版本的定义方法有差异，故我们测试在新集群使用上面的desc信息建表后，再通过import方法导入到HBase。结果依然没有数据写入，可以断定这个参数ENCODE_ON_DISK在HBase1.2.1中完全废弃，新版本采用了一个整字段来包裹这个信息。当老集群有参数时，官方import/export方法在HBase0.9.8到HBase1.2.1直接迁移暂时不可用。

二.后续

在HBase0.9.8集群上建表设置ENCODE_ON_DISK=false（默认为true），在HBase1.2.1上不带ENCODE_ON_DISK建表，使用export/import方法迁移测试
研究其他HBase数据跨集群（版本差异，网络不通）迁移方法

转载于:https://my.oschina.net/u/2987407/blog/781295

相关文章：

  • 旧城镇文兴小学远程教育网点学校工作领导组
  • Struts2 中#、@、%和$符号的用途
  • 项目中常用的几个JS
  • 【uva 658】It's not a Bug, it's a Feature!（图论--Dijkstra或spfa算法+二进制表示+类“隐式图搜索”）...
  • 一个CU的嵌入式BLOG地址
  • React系列之 Redux 架构模式
  • 新Delphi隐藏当前进程
  • [转]iSCSI完全指南
  • 倒计时
  • 11g RAC日志体系（cluster,database,asm,scan日志，ADRCI工具的使用）
  • 管理软件更需要Open Social
  • Android--带你一点点封装项目 MVP+BaseActivity+Retrofit+Dagger+RxJava（一）
  • Unity Application Block 发布
  • 桌面管理系统
  • Javascript 刷新框架及页面的方法总集
  • 分享的文章《人生如棋》
  • Android 初级面试者拾遗（前台界面篇）之 Activity 和 Fragment
  • Angular 响应式表单 基础例子
  • axios请求、和返回数据拦截，统一请求报错提示_012
  • Brief introduction of how to 'Call, Apply and Bind'
  • Python语法速览与机器学习开发环境搭建
  • spring + angular 实现导出excel
  • tensorflow学习笔记3——MNIST应用篇
  • Vue 2.3、2.4 知识点小结
  • 百度小程序遇到的问题
  • 干货 | 以太坊Mist负责人教你建立无服务器应用
  • 基于web的全景—— Pannellum小试
  • 开放才能进步！Angular和Wijmo一起走过的日子
  • 深入浏览器事件循环的本质
  • Mac 上flink的安装与启动
  • #162 (Div. 2)
  • #define
  • #在 README.md 中生成项目目录结构
  • （3）(3.5) 遥测无线电区域条例
  • （30）数组元素和与数字和的绝对差
  • (delphi11最新学习资料) Object Pascal 学习笔记---第7章第3节（封装和窗体）
  • (Python) SOAP Web Service (HTTP POST)
  • （三）Honghu Cloud云架构一定时调度平台
  • （五）c52学习之旅-静态数码管
  • (转) 深度模型优化性能 调参
  • （转）ObjectiveC 深浅拷贝学习
  • .Net 6.0 处理跨域的方式
  • .net wcf memory gates checking failed
  • .net 发送邮件
  • .NET 设计模式初探
  • .NET 实现 NTFS 文件系统的硬链接 mklink /J（Junction）
  • .NET/C# 使窗口永不激活（No Activate 永不获得焦点）
  • .Net6使用WebSocket与前端进行通信
  • .NET实现之(自动更新)
  • @Data注解的作用
  • @Service注解让spring找到你的Service bean
  • @Validated和@Valid校验参数区别
  • [＜事务专题＞]
  • [Android] 240204批量生成联系人，短信，通话记录的APK
  • [AUTOSAR][诊断管理][ECU][$37] 请求退出传输。终止数据传输的（上传/下载）