curator

2熱度

1回答

Apache Curator - Zookeeper連接丟失異常，可能的內存泄漏

我一直在研究一個持續監視分佈式原子長計數器的進程。它使用以下類ZkClient的方法getCounter每分鐘監控一次。實際上，我有多個線程運行，每個線程都監視存儲在Zookeeper節點中的不同計數器（分佈式原子長）。每個線程通過getCounter方法的參數指定計數器的路徑。 public class TagserterZookeeperManager { public enum ZkCl

0熱度

1回答

Zookeeper集羣監視器

我想創建一個基於Zookeeper與CuratorFramework的應用程序。應用程序必須能夠在更多節點上以法定速度運行。每個應用程序實例都嵌入了Zookeeper服務器和客戶端的實例。節點成功地置於法定人數中。每個節點都將一個EPHEMERAL節點寫入/ workers/active/node1（「active」是由leader創建的PERSISTENT znode）。因爲當客戶端連接到zoo

5熱度

2回答

領導人選舉與策展人和動物園管理員

我運行的ZooKeeper的3個實例和配置是這樣的： tickTime=2000 initLimit=10 syncLimit=5 dataDir=/tmp/zookeeper1 clientPort=2181 maxClientCnxns=1000 server.1=127.0.0.1:2888:3888 server.2=127.0.0.1:2889:3889 server.3

9熱度

2回答

Apache Curator「連接字符串」是什麼樣的？

連接字符串如何給CuratorFrameworkFactory#newClient看起來像？到目前爲止，我還沒有在網上找到任何信息，JavaDoc也沒有告訴我正確的格式。

-1熱度

1回答

阿帕奇館長和動物園管理員觀察節點

民間，我們使用Apache館長到我們最近訪問動物園管理員合奏（A，B，C） CuratorFrameworkFactory.newClient（zookeeperConnectionString，retryPolicy）添加了兩個新的觀察者節點（D，E）到這個集合。現在我們的zookeeperConnectionString有A，B，C，D，E 問題 - Curator是否總是從連接字符串中提

0熱度

1回答

是Apache Curator性能？

我對Curator和Zookeeper有什麼高層次的想法。但是，我不知道他們是管理內存還是磁盤上的信息。例如，屏障或分佈式隊列的「receipes」建議在特定路徑上打開節點（節點是文件？）;這些節點是維護在內存中的還是它們在磁盤/ HDFS上的文件？我認爲跨機器的傳統障礙現在需要通過策劃者屏障來完成;因此，如果這些行動涉及繁重的行動，這些行動會不會緩慢？在性能方面，策展人與傳統MPI障礙相比有何

2熱度

1回答

如何在Zookeeper/Curator中進行upsert？

我希望能夠更新或創建它，如果它不存在Zookeeper中的節點。我們正在使用策展人。我可能只是這樣做： CuratorFramework client = ... String path = "/my/interesting/path"; byte[] data = ... client.createContainers(path); client.setData(path, data)

0熱度

2回答

爲什麼在sessiontimeout值之後沒有從zookeeper中刪除外圍節點

我正在CuratorFrameworkFactory.newClient方法的幫助下創建一個Empheral節點，該方法需要znodes地址，sessiontimeoutinms，connectiontimeoutinms，Retry）。我將5 * 1000作爲sessiontimeoutinms和15 * 1000作爲connectiontimeoutinms進行傳遞。這個方法能夠在我的zook

0熱度

1回答

Apache Zookeeper設置的模糊文檔

在此鏈接Official Zookeeper doc中，我發現引用不明確。 ZooKeeper將其數據存儲在數據目錄及其事務日誌中的事務日誌目錄中。默認情況下，這兩個目錄是相同的。服務器可以（也應該）配置爲將事務日誌文件存儲在與數據文件不同的目錄中。當事務日誌駐留在專用日誌設備上時，吞吐量增加和等待時間會減少。它說事務日誌文件應該將事務日誌存儲在一個單獨的目錄中。那麼它說專用設備是最佳的？爲什麼

0熱度

1回答

如何檢查現有Zookeeper Ephemeral節點的超時？

我知道Zookeeper服務器有一個名爲「tickTime」（最小心跳時間= 2 * ticktime）的配置，客戶端可以請求「會話超時」。當連接建立時，它會得到一個會話超時關聯。這是在客戶端和服務器之間進行協商的。如何找到他們雙方均已確定的價值？