分享

hbase 写数据进不去

墨默滴 发表于 2016-6-21 15:19:14 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 5 11403
本帖最后由 墨默滴 于 2016-6-21 15:21 编辑

hbase 1.14 hbase(main):002:0> scan 'test'
ROW                                         COLUMN+CELL                                                                                                                    
row1                                       column=cf:a, timestamp=1461726446872, value=value1                                                                             
row2                                       column=cf:b, timestamp=1461726455672, value=value2                                                                             
row3                                       column=cf:c, timestamp=1461726464420, value=value3                                                                             
3 row(s) in 0.2160 seconds


IDEA读取数据读不到,也写不进去,创建表可以
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;


public class HBaseTestCase {

    public static void createSchemaTables(Configuration cfg) throws IOException {
        try{
            Connection connection = ConnectionFactory.createConnection(cfg);
            Table table = connection.getTable(TableName.valueOf("test"));
            System.out.print(table.toString());
//            Put put = new Put(Bytes.toBytes("row4"));
//            table.put(put);
            Get g=new Get(Bytes.toBytes("row1"));
            try {
                Result result = table.get(g);
                System.out.print(result);
            } finally {
                table.close();
                connection.close();
            }

        }catch (MasterNotRunningException e) {
            e.printStackTrace();
        } catch (ZooKeeperConnectionException e) {
            e.printStackTrace();
        }
    }

    public static void main(String [] args) throws IOException {
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "172.16.0.30");
        conf.set("hbase.zookeeper.property.clientPort", "2181");
        try {
            createSchemaTables(conf);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}





已有(5)人评论

跳转到指定楼层
langke93 发表于 2016-6-21 18:45:17
先确定问题的原因
1.是否是配置的问题
可以通过hbase shell操作,看是否也是读取不到或则不能插入。
如果这样的就是配置问题

2.代码问题
如果是代码的问题,就看下代码,可以参考下面两篇

hbase开发环境搭建及运行hbase小实例(HBase 0.98.3新api)

hbase编程:Eclipse远程连接创建hbase表以及填充列与列数据

回复

使用道具 举报

IT_雪夜归人 发表于 2016-6-22 08:13:43
有什么报错吗?插入不进去的话应该有报错吧
回复

使用道具 举报

墨默滴 发表于 2016-6-22 09:55:42
langke93 发表于 2016-6-21 18:45
先确定问题的原因
1.是否是配置的问题
可以通过hbase shell操作,看是否也是读取不到或则不能插入。

hbase shell正常 ,是用IDEA开发的
回复

使用道具 举报

墨默滴 发表于 2016-6-22 10:16:16
IT_雪夜归人 发表于 2016-6-22 08:13
有什么报错吗?插入不进去的话应该有报错吧

不报错,就是卡一个位置不动了。log4j:WARN No appenders could be found for logger (org.apache.hadoop.metrics2.lib.MutableMetricsFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
test;hconnection-0x5f3f333c //   System.out.print(table.toString());



回复

使用道具 举报

langke93 发表于 2016-6-23 13:26:02
墨默滴 发表于 2016-6-22 10:16
不报错,就是卡一个位置不动了。log4j:WARN No appenders could be found for logger (org.apache.hadoop ...

log4j:WARN 配置下
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条