svn commit: r1349751 - /incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java

[ed...@apache.org]

Author: edwardyoon
Date: Wed Jun 13 11:01:26 2012
New Revision: 1349751

URL: http://svn.apache.org/viewvc?rev=1349751&view=rev
Log: (empty)

Modified:
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java?rev=1349751&r1=1349750&r2=1349751&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPMasterGroomServer.java Wed Jun 13 11:01:26 2012
@@ -39,6 +39,8 @@ import org.apache.hama.examples.ClassSer
 import org.apache.hama.zookeeper.QuorumPeer;
 import org.apache.zookeeper.CreateMode;
 import org.apache.zookeeper.KeeperException;
+import org.apache.zookeeper.WatchedEvent;
+import org.apache.zookeeper.Watcher;
 import org.apache.zookeeper.ZooKeeper;
 import org.apache.zookeeper.ZooDefs.Ids;
 import org.apache.zookeeper.data.Stat;
@@ -152,7 +154,14 @@ public class TestBSPMasterGroomServer ex
     String connectStr = QuorumPeer.getZKQuorumServersString(configuration);
     String bspRoot = configuration.get(Constants.ZOOKEEPER_ROOT,
         Constants.DEFAULT_ZOOKEEPER_ROOT); // Establishing a zk session.
-    ZooKeeper zk = new ZooKeeper(connectStr, timeout, null);
+    ZooKeeper zk = new ZooKeeper(connectStr, timeout, new Watcher() {
+
+      @Override
+      public void process(WatchedEvent arg0) {
+        // do nothing.
+      }
+      
+    });
     // Creating dummy bspRoot if it doesn't already exist.
 
     Stat s = zk.exists(bspRoot, false);