I want information about watcher,
I must develope a MapReduce Yarn application.
I open the zookeeper connection in the main method in WordCount.java class. 
After I have a Map.java class with the map method. In map method i open a new 
zookeeper connection in this way:

final CountDownLatch connectedSignal = new CountDownLatch(1);
                    ZooKeeper zk = new ZooKeeper("localhost:2181", 30000, new 
Watcher() {
                        @Override
                        public void process(WatchedEvent event) {
                                if (event.getState() == 
Watcher.Event.KeeperState.SyncConnected) {
                                        connectedSignal.countDown();
                              }
                        }
                    });

Map class implements Watcher and i add at the end of Map class the process 
method. If i change data on the znode my process method isn’t called!
I wrong sure to set the Watcher :(

Reply via email to