hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject svn commit: r1161136 - /hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java
Date Wed, 24 Aug 2011 14:53:26 GMT
Author: tedyu
Date: Wed Aug 24 14:53:26 2011
New Revision: 1161136

URL: http://svn.apache.org/viewvc?rev=1161136&view=rev
Log:
HBASE-4138 Change debug log in ZKUtil.watchAndCheckExists()

Modified:
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java?rev=1161136&r1=1161135&r2=1161136&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java Wed Aug 24 14:53:26
2011
@@ -219,8 +219,13 @@ public class ZKUtil {
   throws KeeperException {
     try {
       Stat s = zkw.getRecoverableZooKeeper().exists(znode, zkw);
-      LOG.debug(zkw.prefix("Set watcher on existing znode " + znode));
-      return s != null ? true : false;
+      boolean exists = s != null ? true : false;
+      if (exists) {
+        LOG.debug(zkw.prefix("Set watcher on existing znode " + znode));
+      } else {
+        LOG.debug(zkw.prefix(znode+" does not exist. Watcher is set."));        
+      }
+      return exists;
     } catch (KeeperException e) {
       LOG.warn(zkw.prefix("Unable to set watcher on znode " + znode), e);
       zkw.keeperException(e);



Mime
View raw message