【问题标题】:Unable to connect to HBase using Java ?无法使用 Java 连接到 HBase?
【发布时间】:2017-02-26 15:20:05
【问题描述】:

在问这个问题之前,我搜索了很多以解决以下问题但无法解决,如果有人可以帮助解决这个问题。

我已经安装了 hadoop1 2.5.0 和 HBase 0.98.6(在伪 dist 模式下)。我正在尝试运行一个简单的 java 程序来从 hbase 检索数据。我的所有节点都在运行。 我的代码是-

Configuration conf = HBaseConfiguration.create();
conf.set("hbase.master","hadoopHost:60000");
conf.set("hbase.zookeeper.quorum", hBaseZookeeperHostName);
conf.set("hbase.zookeeper.property.clientPort", "2181");
System.out.println("hello");
HTableInterface table = HConnectionManager.createConnection(conf).getTable("user".getBytes());
System.out.println(table.getTableDescriptor().getColumnFamilies().toString());

它正在打印你好,然后它卡住了一段时间,然后简单地结束,没有任何错误或警告。

如果有人能花时间解决这个问题,我对这个大数据世界还是很陌生。

【问题讨论】:

    标签: java hadoop hbase


    【解决方案1】:

    我们可以通过两种方式为 HBase 连接创建配置。

    1. 我们可以在您的类中使用以下行来创建连接,然后在您的类路径中设置 hbase-site.xml。

      配置 conf = HBaseConfiguration.create; HTableInterface table = HConnectionManager.createConnection(conf).getTable("user".getBytes());

    通过这种方式,hbase-site.xml 中定义的值将用于创建连接。

    1. 如果您想覆盖 hbase-site.xml 中的值,您可以从类路径中删除 hbase-site.xml 并根据需要设置参数,就像您在上面的代码中提到的那样。

    由于您尝试使用默认值,我建议您使用选项一。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2016-12-10
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2022-06-12
      • 1970-01-01
      相关资源
      最近更新 更多