Is there any way to update the znode data using Curator.
CuratorFramework client = CuratorClient.createSimple("localhost:2181");
client.start();
Suppose if the node (/my/example/hello) already exists and we just need to
update the znode data. Do I need to execute the below code again just
I have a three node Zookeeper cluster. Let' say three nodes for Zookeeper
are -
NodeA
NodeB
NodeC
And all these three zookeeper nodes are in same DATACENTER. Now I have
couple more machines, let's say I have 6 more machines which are my APP
SERVERS and all these six machines will be c
I am working on a project in which I need to maintain a watches on a node,
and that nodes children as well. I have tried using PathCache but I am not
sure how to watch for childrens children here?
Here my root node is - `"/my/test"` and I am keeping a watch on that node
using the below code. What
drenCache:
> http://curator.apache.org/curator-recipes/path-cache.html
>
> -JZ
>
> --
> From: Check Peck Check Peck
> Reply: user@curator.apache.org user@curator.apache.org
> Date: February 9, 2014 at 9:08:20 PM
> To: user user@curator.apache.org
> Subject:
heard back from him..
>
> -JZ
>
> ----------
> From: Check Peck Check Peck
> Reply: Check Peck comptechge...@gmail.com
> Date: February 9, 2014 at 9:35:24 PM
> To: Jordan Zimmerman jor...@jordanzimmerman.com
> Subject: Re: How to watch on descendant znodes using Curator PathCache?
>
&
t; node. When CHILD_REMOVED is sent, close and remove it. So, what you end
> with is a map of PatchChildrenCache/NodeCache instances.
>
> So, this is off the top of my head and I haven't thought through all the
> edge cases. If it works, though, it might make a nice recipe add
Below is my `CuratorClient` class which is connecting to Zookeeper and
starting the leader election process as well.
public class CuratorClient {
// can I make this as static?
private static CuratorFramework clie
y understanding is wrong..
On Thu, Feb 20, 2014 at 8:32 PM, Jordan Zimmerman <
jor...@jordanzimmerman.com> wrote:
> You only need 1 CuratorFramework instance per ZooKeeper cluster. So, yes.
> Stylistically, though, all that static stuff should be avoided, IMO.
>
> -JZ
>
&
I am using Netflix Curator library as I am working with Zookeeper. And now
I am trying to write junit test for my code base so I need to mock some of
the codes for Curator library.
I am using jmockit library for mocking.
This is my below code which creates a simple znode in the zookeeper.
Cu
I am using Curator library for Zookeeper. I am using zookeeper to monitor
whether my app servers are up or not. If they are not up or shut down, then
bring them up. I need to keep a watch on three of my znodes on the
zookeeper. I am keeping a watch on ("/test/proc/phx/server",
("/test/proc/slc/serv
nt thread to keep processing stuff.
>
>
> On Thu, Jul 24, 2014 at 6:33 AM, Check Peck
> wrote:
>
>> I am using Curator library for Zookeeper. I am using zookeeper to monitor
>> whether my app servers are up or not. If they are not up or shut down, then
>> bring the
EventA, B and C
> called at the same time. This may be fine for you, but something to keep in
> mind.
>
> If this is an issue, then instead of passing the executor to the
> addListener call, you can call your executor directly from the childEvent()
> method whenever you need to
, Jul 23, 2014 at 9:07 PM, Jordan Zimmerman <
jor...@jordanzimmerman.com> wrote:
> Yes. Though, I don’t know why you’d use a fixed thread pool.
>
>
> From: Check Peck
> Reply: user@curator.apache.org >
>
> Date: July 23, 2014 at 11:06:42 PM
> To: user >
> C
We have a three node zookeeper cluster and we are also using Exhibitor on
top of each zookeeper node.
Suppose if any of the zookeeper node goes down or having any errors or
issues then is there any way that it can be restarted?
I noticed on Exhibitor UI of my zookeeper nodes there is a button fo
Checking again to see whether anyone know the answer?
On Wed, Sep 24, 2014 at 8:56 AM, Check Peck wrote:
> We have a three node zookeeper cluster and we are also using Exhibitor on
> top of each zookeeper node.
>
> Suppose if any of the zookeeper node goes down or having any errors
tor can be used as a co-process to restart down instances. It
> can also completely manage your ensemble if you like.
>
> -JZ
>
>
> On October 1, 2014 at 3:34:10 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Checking again to see whether anyone know the answer?
>
it if it is down?
On Wed, Oct 1, 2014 at 2:18 PM, Jordan Zimmerman wrote:
> Yes
>
>
> On October 1, 2014 at 4:17:00 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Thanks Jordan. One last question, as of now it is showing *OFF* next to
> *Automatic
> Instance Res
n Tomcat and had company wide tools that would watch our Tomcat
> processes.
>
>
> On November 5, 2014 at 12:47:52 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Hi Jordan,
>
> I have one more question on this. As you told me, if zookeeper went down,
> then exhibit
I am using Zookeeper for the leadership election process. I have three
nodes zookeeper ensemble.
We have a node like this "/test/msn" on which we are doing the leadership
election and it works fine and we have application servers running it in
production and using "/test/msn" node for leadership.
t notified. Alternatively, you can use LeaderSelector.
>
> Hope this helps.
>
> -Jordan
>
>
>
> On January 15, 2015 at 5:25:26 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> I am using Zookeeper for the leadership election process. I have three
> nodes zookeeper en
d the code too fast. I guess it doesn’t make more than one…
>
> There’s an example of LeaderSelector here:
> http://curator.apache.org/curator-examples/index.html
>
>
> On January 15, 2015 at 6:00:03 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Thanks Jordan for
e
> benefit of LeaderSelector is that it has a callback that is invoked when
> you are the leader. Remember, you are in a multithreaded, multi client
> environment. Only 1 client is going to be the leader. Maybe what you are
> after is an InterProcessMutex?
>
> -JZ
>
>
>
> O
As of now, I am adding a sleep of 1 minute and it works fine before I check
whether I am a leader or not.
On Thu, Jan 15, 2015 at 3:43 PM, Check Peck wrote:
> Yes that makes sense that 1 client will be leader. But suppose I have 5
> background threads running in 5 different machines an
>> If you use the callback as Jordan suggested, then you can just block
>> on a latch, and then get this latch to be updated by the callback when it
>> is notified that it's leader. Then you won't have to wait for some fixed
>> amount of time, it will just block until
Hi Jordan,
How can we build 1.5.3 exhibitor locally? Earlier, I was following this
link to do that -
https://github.com/Netflix/exhibitor/wiki/Building-Exhibitor
But in that link, I can still see in the pom file, that version is "1.5.1".
Do I just need to change that to "1.5.3"? And build it same
gt; -JZ
>
>
>
> On February 8, 2015 at 7:16:19 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Hi Jordan,
>
> How can we build 1.5.3 exhibitor locally? Earlier, I was following this
> link to do that -
> https://github.com/Netflix/exhibitor/wiki/Building-Exhibit
I have followed this wiki (
https://github.com/Netflix/exhibitor/wiki/Building-Exhibitor) to build the
standalone version of exhibitor. I was following maven way of doing it. I
just edited the pom to have "1.5.3" version of Exhibitor and then ran this
command
mvn assembly:single
which generated
Zimmerman wrote:
> Yeah - I saw the same problem. I’ve changed it to use the Shader plugin
> and it works now. I’ve updated the wiki (and POM):
>
> https://github.com/Netflix/exhibitor/wiki/Building-Exhibitor
>
> -Jordan
>
>
>
> On February 8, 2015 at 10:58:39 PM, Check
On Wed, Mar 4, 2015 at 8:25 PM, Jordan Zimmerman wrote:
> Fixed Gradle uber JAR build
Is this also fixed?
https://github.com/Netflix/exhibitor/issues/226
I have a simple requirement as I am using Zookeeper with Curator. I have a
znode like this "/test/clients/" and some other application will create a
znode under "/test/clients/" with some data in it and those are each task
that my other three machines has to perform so it will be like this:-
This
use it directly, you can use the code as a sample of how
> to do what you want.
>
> -Jordan
>
> On September 4, 2015 at 3:18:23 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> I have a simple requirement as I am using Zookeeper with Curator. I have a
> znode like this &
Is there any way we can find childrens of a given znode which is 30 days
old using curator? I mean the node which doesn't had any activity for last
30 days or X days.
public List getChildrenOfANode(final String path) throws
Exception {
return client.getChildren().forPath(path);
}
lue you want (I forget which).
>
> -JZ
>
>
> On September 8, 2015 at 9:03:49 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Is there any way we can find childrens of a given znode which is 30 days
> old using curator? I mean the node which doesn't had any activi
Hi Jordan,
I was looking at this email which you sent me long time back. Here you
mentioned - If I call getChildren(), the entire length of all the children
can't exceed 1MB. Suppose, I have 500 clients as client_0, client_1 etc.
And each client has 50-60 znodes with some data in it.
List childr
more than 1MB in each znode
correct?
On Sun, Sep 13, 2015 at 1:57 PM, Jordan Zimmerman <
jor...@jordanzimmerman.com> wrote:
> The node names. Internally, ZooKeeper’s protocol is (by default) limited
> to 1MB per response.
>
> -JZ
>
>
>
> On September 13, 2015 at 3:44:10
jor...@jordanzimmerman.com> wrote:
> No, the 1MB limit will hit you there as well. If you try to get your data
> (via getData() call) it will fail. Note, you can increase the value via the
> jute.maxBuffer property.
>
> -Jordan
>
> On September 13, 2015 at 4:06:48 PM, Check Pe
I mean this code for getting children not earlier one, that is for data.
List children = client.getChildren().forPath(path);
On Sun, Sep 13, 2015 at 2:10 PM, Check Peck wrote:
> Ok understood that part and I was correct on the 500 children nodes znode
> name example right?
>
&
r what though).
>
> -Jordan
>
>
>
> On September 13, 2015 at 4:11:19 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> Ok understood that part and I was correct on the 500 children nodes znode
> name example right?
>
> If I can increase the jute.maxBuffer property,
<
jor...@jordanzimmerman.com> wrote:
> Yes, all clients. Curator just wraps ZooKeeper so all the same things
> apply.
>
> -Jordan
>
>
>
> On September 13, 2015 at 4:14:17 PM, Check Peck (comptechge...@gmail.com)
> wrote:
>
> I mean this code for getting children
I am seeing very weird issue when using DistributedQueue recipe in Curator.
I am thinking it might be a bug in Zookeeper or Curator but not sure yet or
may be I am doing something silly.
I am trying to queue message in Zookeeper using DistributedQueue recipe:
public void queueMessages() throw
Does anyone have any thoughts on this?
On Fri, Sep 18, 2015 at 9:39 PM, Check Peck wrote:
> I am seeing very weird issue when using DistributedQueue recipe in
> Curator. I am thinking it might be a bug in Zookeeper or Curator but not
> sure yet or may be I am doing something silly.
shouldn't even compile.
>
> -Martin
>
> On 09/23/2015 05:12 PM, Check Peck wrote:
> >Does anyone have any thoughts on this?
> >>On Fri, Sep 18, 2015 at 9:39 PM, Check Peck >wrote:
> >>>I am seeing very weird issue when using DistributedQueue recipe in
&g
I have a zookeeper ensemble of 5 servers and I am using exhibitor on top
of it. And I installed exhibitor and setup zookeeper by following this link:
https://github.com/soabase/exhibitor/wiki/Building-Exhibitor
Below is how all my zookeeper machines are setup in exhibitor
S:1:machineA,
43 matches
Mail list logo
