- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我正在尝试使用 Java 中的 Apache Curator 库中的事务将数据写入 ZooKeeper。
这是我的代码:
private CuratorFramework client;
...
private void writeToZK() {
String nodePath = "/path/to/node";
client.inTransaction().create().forPath(nodePath).and().commit(); // problem
}
(我使用的是 curator v2.9.0)
抛出:
org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode
at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
at org.apache.zookeeper.ZooKeeper.multiInternal(ZooKeeper.java:949)
at org.apache.zookeeper.ZooKeeper.multi(ZooKeeper.java:915)
我深入研究了 ZooKeeper.multiInternal(),它得到了包含 zookeeper 的响应
OpResult: err = -101, type = -1.
如果我用这个替换“//problem”行,它会起作用:
client.create().creatingParentsIfNeeded().forPath(nodePath); // runs with no problem
有什么想法吗?
最佳答案
在 zookeeper 中,每个节点都定义了一个路径。请查看文档:https://zookeeper.apache.org/doc/trunk/zookeeperOver.html它们的组织方式类似于标准文件系统。这意味着如果“/path/to”不存在,则不能创建 >“/path/to/node”。您提出的解决方案是正确的,因为如果您的节点的父节点不存在,它将由 zookeeper 自动创建。
关于java - CuratorTransaction KeeperErrorCode = NoNode,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41385301/
我正在尝试使用 Java 中的 Apache Curator 库中的事务将数据写入 ZooKeeper。 这是我的代码: private CuratorFramework client; ... pr
当我启动 kafka 时,zookeeper 发生错误。 INFO Got user-level KeeperException when processing sessionid:0x1560286
我写了一个 kafka 消费者和生产者,直到今天都运行良好。 今天早上,当我启动zookeeper和kafka时,我的消费者无法读取消息,我在zookeeper日志中发现了这一点: INFO Got
我使用以下 Apache Curator Maven 依赖项: org.apache.curator curator-x-async 4.0.
我正在使用以下代码从 zookeeper 中提取 Kafka 代理列表: private static String getBrokerList() { try {
在 hbase shell 中执行任何命令时,我在 hbase shell 中收到以下错误“错误:KeeperErrorCode = NoNode for/hbase/master”。 启动 HBAS
在启动 Kafka 时出现以下错误。 KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions 任何帮助将不胜感激。 最佳答
情况 首先,我必须提到我正在使用 Solr 8.1.1 并运行默认的“solr -e cloud”来进行一些测试。这是在 Windows Azure VM 上运行的。我正在尝试创建一个 PowerSh
我尝试在伪分布式模式下安装hbase。现在我不能使用 hbase。 hbase shell 中的所有代码都无法运行,并且所有代码都得到此错误提示: ERROR: KeeperErrorCode = N
我尝试在伪分布式模式下安装hbase。现在我不能使用 hbase。 hbase shell 中的所有代码都无法运行,并且所有代码都得到此错误提示: ERROR: KeeperErrorCode = N
尝试以 Hbase Standalone 方式创建新表时出现此错误。 hbase:002:0> create 'test', 'cf' ERROR: KeeperErrorCode = Connect
我正在使用zookeeper 3.4.6,我使用acl来通过zookeeper服务器进行身份验证。我有自己的实现 ZooKeeperSupport,它支持创建、删除和验证 znode。我正在尝试使用
在为代理到 Zookeeper 身份验证实现 SSL 时,我在代理 2 节点上遇到了以下异常 从 SSL 设置中,集群配置了 SSL 身份验证 Broker 1 成功连接到 zookeeper,但在
我已经下载了 Solr 4.10.3,使用提供的设置运行服务器,我可以使用 SolrJ(v. 4.0.0)通过使用 HttpSolrServer 将文档插入其中。没有任何问题。但是当我尝试使用 Clo
我是一名优秀的程序员,十分优秀!