ZOOKEEPER-907. Spurious "KeeperErrorCode = Session moved" messages
git-svn-id: https://svn.apache.org/repos/asf/hadoop/zookeeper/branches/branch-3.3@1031064 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt
index efff07d..78e7f80 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -64,6 +64,8 @@
ZOOKEEPER-898. C Client might not cleanup correctly during close
(jared cantwell via mahadev)
+ ZOOKEEPER-907. Spurious "KeeperErrorCode = Session moved" messages (vishal k via breed)
+
IMPROVEMENTS:
ZOOKEEPER-789. Improve FLE log messages (flavio via phunt)
diff --git a/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java b/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
index b2f1ded..fdbf023 100644
--- a/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
+++ b/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
@@ -449,14 +449,14 @@
cxid = bb.getInt();
type = bb.getInt();
bb = bb.slice();
+ Request si;
if(type == OpCode.sync){
- leader.zk.submitRequest(new LearnerSyncRequest(this, sessionId, cxid, type, bb,
- qp.getAuthinfo()));
+ si = new LearnerSyncRequest(this, sessionId, cxid, type, bb, qp.getAuthinfo());
} else {
- Request si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());
- si.setOwner(this);
- leader.zk.submitRequest(si);
+ si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());
}
+ si.setOwner(this);
+ leader.zk.submitRequest(si);
break;
default:
}
