curator
curator copied to clipboard
apache
Apache Curator
I was using CuratorFramework and was unable to see some expected session expiration events. Here's a simpler demonstration of these missed events (without using CuratorFramework) Code that works: This code...
According to the documentation at https://curator.apache.org/apidocs/org/apache/curator/SessionFailRetryLoop.html the canonical usage of SessionFailRetryLoop is: SessionFailRetryLoop retryLoop = client.newSessionFailRetryLoop(mode); retryLoop.start(); try { while ( retryLoop.shouldContinue() ) { try { // do work }...
According to http://curator.apache.org/curator-recipes/distributed-queue.html#Error_Handling, the QueueConsumer implementer can receive connection state updates. However, in fact, my consumer is never notified of any state updates when the connection is down. By checking...
We noticed that if GC pause > session timeout and even if retry policy is set, Curator doesn't retry. We use CuratorFramework.getConnectionStateListenable to listen on connection state. ConnectionState.LOST is received...
TestCleanState is used in finally blocks in lots of tests to close the Curator handle and check for cleaned watchers. However, being in a finally, it always runs. If there...
Here is the problem I’m meeting: Assuming 3 node ensemble, my application has 3 clients and each one runs on same zk node (Client 1, 2 and 3). They use...
Curator probably has some thread leaks. The tests should be enhanced to find them and fixes should be applied. --- Originally reported by randgalt, imported from: Find/fix all thread leaks...
We need store InterProcessMutex (so that it can be used for Reentrant) in a map when we acquire a lock and remove it when we release it. It good to...
Bumps org.apache.zookeeper:zookeeper from 3.5.7 to 3.8.4. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
CURATOR-495 introduced a new runSafeService field in CuratorFrameworkImpl class, and this field is either initialized by an external ExecutorService via the builder, or it is created internally within the class....
