You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by ma...@apache.org on 2010/01/21 02:44:59 UTC
svn commit: r901496 - in /hadoop/zookeeper/trunk: CHANGES.txt
src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
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;