我对Hbase感到非常陌生,它与RDBMS确实不同。我开发了一个简单的应用程序,并尝试将其配置为远程服务器162.18.17.55。我收到拒绝连接的错误。我无法转发检查哪里出错了,当我在Putty中键入zk_dump时,我得到了各自的服务器详细信息,可以登录到腻子并将表插入数据库,但是当我使用Java客户端时,我无法连接到服务器。请谁能指导我这个过程和问题 解决方案如下: 当您连接到Zookeeper时,由于您将HadoopMaster放入HadoopMaster文件中,因此它将core-site.xml作为主机而…

2020年11月6日 0条评论 44点热度 阅读全文

nano conf/zoo.cfg tickTime=2000 dataDir=/var/lib/zookeeper clientPort=2181 initLimit=5 syncLimit=2 server.1=10.0.0.2:2888:3888 server.2=10.0.0.3:2888:3888 server.3=10.0.0.4:2888:3888 我正在尝试了解此cfg文件。 clientPort用于传入通信,对吗?但是,为什么还要再有两个这样的端口: server.1=10.0.0.2:2888:…

2020年10月28日 0条评论 55点热度 阅读全文

我在一家小型软件公司工作,负责研究分布式锁管理器供我们使用。它必须同时与Java和C++交互。 我已经与ZooKeeper一起工作了几周,现在需要实现死锁检测have implemented shared locks (read and write locks) according to the documentation.。如果每个客户端都可以维护一个锁图,那将是快速而简单的。但是,you cannot reliably see every change that happens to a node in Zoo…

2020年10月25日 0条评论 59点热度 阅读全文

我必须将hbase进程启动到私有(private)hadoop集群,并且需要简单地演示最少的功能;该演示不需要安装hadoop。继QuickStart apache hbase文档通过 shell 失败后,我已经能够使用自包含的maven项目来复制失败。 /etc/hosts不是问题。 我找到了一个Maven项目,该项目似乎是为了消除这种相同功能而构建的,并更新了部门。 该项目在这里:hbase-demo 要重复我的结果,需要 shell 程序和安装了maven的两行代码: git clone https://gi…

2020年10月14日 0条评论 50点热度 阅读全文

我正在尝试使用Java API在hbase表中填充数据,但是没有将数据插入表中。这是我的代码。 public static void main(String[] args) throws Throwable{ Configuration config = HBaseConfiguration.create(); config.set("hbase.zookeeper.quorum", "192.168.133.4:2181"); config.set("hbase.zookeeper.quorum", "192.1…

2020年9月26日 0条评论 35点热度 阅读全文

我在AWS EKS集群版本1.15中以复制模式(总共3个zookeeper节点)运行Zookeeper 3.6.0。我正在从Docker集线器中获取zookeeper:最新图像。 这是节点1(prd-zoo1)的zoo.cfg文件。除了指定了其他Zoo服务器的最后三个条目之外,其他节点具有类似的配置。 zoo.cfg Node 1: dataDir=/data dataLogDir=/datalog tickTime=2000 initLimit=5 syncLimit=2 autopurge.snapRetain…

2020年9月16日 0条评论 34点热度 阅读全文

我是动物园管理员的新手。我已经编写了创建持久节点的简单程序。它的工作,但一旦执行完成给予异常(exception)。我试图在谷歌上搜索,但没有令人满意的答案。谁能给我任何建议。 public class ZkProg { public static void main(String[] args) throws IOException, KeeperException, InterruptedException { ZooKeeper zk=new ZooKeeper("localhost",1281, null)…

2020年9月16日 0条评论 34点热度 阅读全文

我正在尝试连接到安装在ubuntu vm上的远程hbase-0.94.8。我有一个TableNotFoundException,这是我的Java代码: Configuration config = HBaseConfiguration.create(); config.set("hbase.zookeeper.quorum", "192.168.56.101"); HTableInterface usersTable = new HTable(config, "users"); 这是完整的异常跟踪: 14/06/2…

2020年9月8日 0条评论 31点热度 阅读全文

Zookeeper客户端启动时,将创建2个线程:SendThread和EventThread。在应用程序关闭时,我希望工作线程等待Zookeeper线程完成,但是在API中看不到任何合适的东西。 但是我只能调用ZooKeeper.close(),它将连接状态设置为CLOSED,并为EventThread排队“死亡事件”。从ClientCnxn: public void disconnect() { this.sendThread.close(); this.eventThread.queueEventOfDeath…

2020年9月4日 0条评论 33点热度 阅读全文

我已经创建了一个示例Java程序来在HBase中创建一个表,它显示成功创建了该表。但是当我打开HBase终端并使用list命令时,创建的表不存在。为什么会这样?我的代码如下 Configuration config = HBaseConfiguration.create(); conf.set("hbase.master","192.168.1.47:60000"); Configuration config = HBaseConfiguration.create(); config.set("hbase.zook…

2020年8月26日 0条评论 43点热度 阅读全文