java - HBase无法启动

Question

我正在尝试从Java客户端api在hbase中建立连接。

这是我的代码。在这里，我写了一些代码来获取hbase中的连接。

运行此代码时，我没有收到任何错误。但是我不能用这个创建任何表。

Configuration hbaseConfiguration = HBaseConfiguration.create();
    try {

        hbaseConfiguration.set("hbase.rootdir",
                "file:///home/sample/hbase");
        hbaseConfiguration.set("hbase.zookeeper.property.dataDir",
                "/home/sample/zookeeper");
        hbaseConfiguration.set("hbase.zookeeper.quorum",
                "sample");
        Configuration newConfig = new Configuration(hbaseConfiguration);
        HConnection connection = HConnectionManager
                .getConnection(newConfig);
        hBaseAdmin = new HBaseAdmin(connection);
        hBaseAdmin.createTable(new HTableDescriptor("sample"));
        if (!hBaseAdmin.isMasterRunning())
            throw new Exception("Hbase is not running");
        tableFactory = new HTableFactory();
    } catch (Exception e) {
        throw new Exception("Hbase is not running");
    }

有人可以帮我吗？谢谢....

Answer 1

更改以下代码

    hbaseConfiguration.set("hbase.rootdir",
            "file:///home/sample/hbase");
    hbaseConfiguration.set("hbase.zookeeper.property.dataDir",
            "/home/sample/zookeeper");
    hbaseConfiguration.set("hbase.zookeeper.quorum",
            "sample");

至

hbaseConfiguration.set("hbase.zookeeper.quorum",
            "rs1.example.com");

注意:rs1.example.com应该替换为指向zookeeper群集的地址。您可以在conf/hbase-site.xml中找到该值。