微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Java连接Hbase和Phoenix失败

如何解决Java连接Hbase和Phoenix失败

HBase 和 Hadoop 在 docker 中是 CDH 独立模式。 ZK、hbase、phoenix使用shell都可以运行。 java操作zk也可以,但是java不能操作Hbase和phoenix,代码可以。 谁能帮帮我,谢谢!

    words = list(model.wv.index_to_key)

运行代码后的日志:

    public class HbaseTest {
    public static Configuration conf;
    static{
        conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum","master:2181");
    }
    public static void main(String[] args) throws Exception {
        Connection connection = ConnectionFactory.createConnection(conf);
        HBaseAdmin admin = new HBaseAdmin(conf);
        boolean exists = admin.tableExists("stu");
        System.out.println(exists);
        admin.close();
    }
}

解决方法

您应该尝试将仲裁的地址和端口分开

conf.set("hbase.zookeeper.quorum","master");
conf.set("hbase.zookeeper.property.clientPort","2181");

另外,你确定你的zookeeper在master节点上吗?第一个属性不应该是主地址,而是zookeeper quorum(用逗号分隔,如果它是多个地址)。我想您指定了“master”是因为您将 master 和单个 zookeeper 节点放在一起?

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。