curator

0熱度

1回答

org.apache.zookeeper.KeeperException $ ConnectionLossException：KeeperErrorCode = ConnectionLoss for/lock/test3_node

我使用Curator客戶端來操作zookeeper服務器，但如果我啓動10個線程來同時操作zookeeper服務器，則總是失敗。它工作正常，如果線程數小於6，而發生連接丟失，我必須重新啓動zookeeper服務器。有人知道如何解決這個問題？。 curatorClient = CuratorFrameworkFactory.builder().connectString(zkAddress).s

0熱度

1回答

調用其他節點的策展人領導人選舉例如

以阿帕奇館長的Example leader selector code的，它很容易，同時領導者執行某些任務，但如何才能給任務中的領導者選舉過程中的其他參與者？例如，如果一個節點有方法 void doWork(){ System.out.println(1); } 我想有領導告訴這樣其他參與者節點完成工作，我怎麼可以這樣做？

11熱度

4回答

阿帕奇館長未實現的錯誤當試圖創建zNodes

我試圖使用Apache館長與dockerized動物園管理員實例，不管我怎麼嘗試連接我總是帶着 org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for... 錯誤告終。我已經嘗試瞭解文檔，但我沒有得到任何地方。我已經登錄到動物園管理員CLI並確保端口號是正確正是

0熱度

1回答

館長後臺操作重試放棄了

我的代碼是這樣的： String zkAddress = "..."; // example ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client = CuratorFrameworkFactory.builder() .conne

2熱度

2回答

使用curator treeCache時，如何確保緩存準備就緒？

使用館長treeCache時，如何確保緩存準備就緒？ cache.start()之後，如果我立刻打電話給getCurrentData，它會返回null，那麼如何確保緩存準備就緒？，有人可以舉個例子嗎？由於 client = CuratorFrameworkFactory.builder() .connectString(connectionString) .retryP

0熱度

1回答

Netflix策展人交易錯誤

在創建路徑時，我在下面的代碼中收到了NodeExists錯誤。 CuratorTransaction transaction = curatorFramework.inTransaction(); transaction.create().forPath("/foo") .and().create().forPath("/foo/123") .and().create()

2熱度

1回答

Java DNS解析永遠掛起

我正在使用curator框架連接到動物園管理員服務器，但遇到奇怪的DNS解析問題。這裏是jstack轉儲線程， #21 prio=5 os_prio=0 tid=0x0000000001888800 nid=0x3a46 runnable [0x00007f25e69f3000] java.lang.Thread.State: RUNNABLE at java.net.Inet4Add

2熱度

1回答

當ZooKeeper在ZooKeeper服務器中有領導者選舉時，爲什麼策展人會在'流程'中進行領導者選舉？

我最近了解到ZooKeeper及其設計。我明白一個ZooKeeper服務是由多個ZooKeeper服務器支持的，但是，有必要選擇其中一個服務器作爲組的負責人。接下來，我開始通過LeaderLatch和LeaderElection的阿帕奇館長食譜去的，而不是談論選擇的領導者，他們談論選擇過程的領導者（組織者）。我對此感到困惑。有人可以幫助並向我澄清爲什麼策展人配方和ZooKeeper談論兩種不

1熱度

1回答

在多個Spark Executors上共享Zookeeper配置

我有一個在Zookeeper中寫入的配置信息。我使用Apache Curator來閱讀Curator Watcher的配置（如果有更好的解決方案來閱讀它，我很樂意使用它），所以如果在Zookeeper中更改配置，我會收到新配置。我在Spark中使用這個配置。我怎樣才能將它分享給同一應用程序的所有火花執行者？謝謝！ LE：謝謝Dikei，在下面的代碼，在這裏，你會做觀察者實現？我是新來的星星，

1熱度

2回答

將多個Curator連接到一個Zookeeper實例？

是否可以將多個策劃者連接到同一個Zookeeper實例？如果是的話如何？看來Zookeeper只有一個客戶端端口。這需要出現，因爲在測試期間我需要將一些初始化數據寫入Zookeeper，但目前我已經有了連接到Zookeeper的主要館長實例（我沒有訪問權限）。