You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2011/08/24 16:53:26 UTC
svn commit: r1161136 -
/hbase/trunk/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java
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);