zoukankan      html  css  js  c++  java
  • HBase写入操作卡住长时间不返回的原因分析

    本文出处:http://blog.csdn.net/chaijunkun/article/details/44238163,转载请注明。

    由于本人不定期会整理相关博文,会对相应内容作出完好。因此强烈建议在原始出处查看此文。


    这些天研究HBase。写了一段Demo代码。详细例如以下:

    @Test
    public void doTest() throws MasterNotRunningException, ZooKeeperConnectionException, IOException {
    	Configuration config = HBaseConfiguration.create();
    	config.set(zkSetKey, zkConn);
    	HBaseAdmin hBaseAdmin = null;
    	try{
    		hBaseAdmin = new HBaseAdmin(config);
    		ClusterStatus clusterStatus = hBaseAdmin.getClusterStatus();
    		ServerName master = clusterStatus.getMaster();
    		log.info("Master主机:{},port号:{}", master.getHostname(), master.getPort());
    		Collection<ServerName> servers = clusterStatus.getServers();
    		for (ServerName serverName : servers) {
    			log.info("Region主机{},port号:{}", serverName.getHostname(), serverName.getPort());
    		}
    		HTableDescriptor targetTableDesc = null;
    		try{
    			targetTableDesc = hBaseAdmin.getTableDescriptor(TableName.valueOf(tableName));
    			log.info("表已经存在,显示信息");
    			log.info("属性:{}", targetTableDesc.toString());
    		}catch(TableNotFoundException notFound){
    			log.info("表不存在,创建");
    			HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(tableName));
    			HColumnDescriptor hcd_info = new HColumnDescriptor("info");
    			hcd_info.setMaxVersions(3);
    			HColumnDescriptor hcd_data = new HColumnDescriptor("data");
    			htd.addFamily(hcd_info);
    			htd.addFamily(hcd_data);
    			hBaseAdmin.createTable(htd);
    			log.info("创建成功");
    			targetTableDesc = hBaseAdmin.getTableDescriptor(TableName.valueOf(tableName));
    			log.info("属性:{}", targetTableDesc.toString());
    		}
    		TableName[] listTableNames = hBaseAdmin.listTableNames();
    		if (listTableNames == null){
    			log.info("无表");
    		}else{
    			for (TableName tableName : listTableNames) {
    				log.info("表名:{}", tableName.getNameAsString());
    			}
    		}
    	}finally{
    		IOUtils.closeQuietly(hBaseAdmin);
    		log.info("结束");
    	}
    }
    执行这段代码程序会卡在第28行不动。也就是创建表操作,而且没有报出不论什么异常,其他的读取操作却非常快(比如获取集群状态、列出全部表等操作)。于是本人陷入了深深地思考……

    在CSDN找到了一种相似的情况:http://blog.csdn.net/lxpbs8851/article/details/8287471

    主要是说HBase所依赖的HDFS进入了安全模式,须要手动退出该模式(执行命令:hdfs dfsadmin -safemode leave)。

    但是我查询当前的HDFS安全模式状态(hdfs dfsadmin -safemode get)时得到的信息是:Safe mode is OFF。也就是说根本没在安全模式下。


    后来偶然地过了一段时间再去看日志发现例如以下信息:

    #1, waiting for some tasks to finish. Expected max=0, tasksSent=9, tasksDone=8, currentTasksDone=8, retries=8 hasError=false, tableName=demo_table
    #1, waiting for some tasks to finish. Expected max=0, tasksSent=10, tasksDone=9, currentTasksDone=9, retries=9 hasError=false, tableName=demo_table
    #1, table=demo_table, attempt=10/35 failed 1 ops, last exception: java.net.UnknownHostException: unknown host: admin.demo.com on admin.demo.cn,5020,1426211698289, tracking started Fri Mar 13 11:41:19 CST 2015, retrying after 10037 ms, replay 1 ops.


    最后一行的主机名:admin.demo.com和admin.demo.cn引起了我的注意。由于我的測试环境为3台实体服务器,配置例如以下:

    IP地址hosts文件配置的主机名linux系统的hostnameHBase角色HDFS角色
    192.168.1.21hd-21test-21MasterServerNameNode、DataNode、ZooKeeper
    192.168.1.22hd-22test-22RegionServerNameNode、DataNode、ZooKeeper
    192.168.1.23hd-23test-23RegionServerDataNode、ZooKeeper
    另外。由于是測试环境,在192.168.1.22这台机器上还增加了例如以下hosts信息:

    192.168.1.22 admin.demo.com
    192.168.1.22 admin.demo.cn
    简单来说就是hosts文件里配置的主机名和真实主机名不一致,而且还增加了额外的hosts配置信息干扰到了正确解析主机名。

    执行demo程序的工作机没有配置不论什么额外的hosts,连接ZooKeeper时直接使用的IP地址。但是HBase Client 底层在进行操作时可能引入了主机名反向连接。作为全然干净的工作机当然找不到相应的服务器,就不断地在后台重试导致生成了上述的日志。当我把出现故障的两个hosts记录增加到工作机后,问题解决


    经验:通过上述错误可知,Hadoop集群中hostname一定要与hosts文件里配置的名称一致,而且力求保证集群映射关系的纯净。不要把其他不相干的业务也部署在当中,引起不必要的麻烦。

  • 相关阅读:
    Web服务器和应用服务器的区别
    Java程序员应该知道的10个调试技巧
    java快捷键个人总结
    MySQL主从复制与读写分离
    CDN(内容分发网络)技术原理
    淘宝技术发展
    Monitor a Folder using Java
    Android eclipse中程序调试
    在学校教学Java是有争议的
    LINUX ubuntu 12.04 svn 1.6.7 苦逼的装了一个下午啊!! 绝对详细!正确!不吭爹!!
  • 原文地址:https://www.cnblogs.com/llguanli/p/7083552.html
Copyright © 2011-2022 走看看