hadoop-zookeeper-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maha...@apache.org
Subject svn commit: r901496 - in /hadoop/zookeeper/trunk: CHANGES.txt src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
Date Thu, 21 Jan 2010 01:44:59 GMT
Author: mahadev
Date: Thu Jan 21 01:44:55 2010
New Revision: 901496

URL: http://svn.apache.org/viewvc?rev=901496&view=rev
Log:
ZOOKEEPER-608. Receipt of ACK from observer should not be logged as ERROR (henry via mahadev)

Modified:
    hadoop/zookeeper/trunk/CHANGES.txt
    hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java

Modified: hadoop/zookeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/CHANGES.txt?rev=901496&r1=901495&r2=901496&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/CHANGES.txt (original)
+++ hadoop/zookeeper/trunk/CHANGES.txt Thu Jan 21 01:44:55 2010
@@ -199,6 +199,9 @@
   ZOOKEEPER-651: Log exception trace in QuorumCnxManager.SendWorker 
   (flavio via henry)
 
+  ZOOKEEPER-608. Receipt of ACK from observer should not be logged as ERROR
+  (henry via mahadev)
+
 IMPROVEMENTS:
   ZOOKEEPER-473. cleanup junit tests to eliminate false positives due to
   "socket reuse" and failure to close client (phunt via mahadev)

Modified: hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java?rev=901496&r1=901495&r2=901496&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
(original)
+++ hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
Thu Jan 21 01:44:55 2010
@@ -367,7 +367,9 @@
                 switch (qp.getType()) {
                 case Leader.ACK:
                     if (this.learnerType == LearnerType.OBSERVER) {
-                        LOG.error("Received ACK from Observer  " + this.sid);
+                        if (LOG.isDebugEnabled()) {
+                            LOG.debug("Received ACK from Observer  " + this.sid);
+                        }
                     }
                     leader.processAck(this.sid, qp.getZxid(), sock.getLocalSocketAddress());
                     break;



Mime
View raw message