diff options
Diffstat (limited to 'zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java')
-rw-r--r-- | zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java index b6eeb758a..1818bf9bb 100644 --- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java +++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java @@ -804,9 +804,7 @@ public class Learner { continue; } packetsCommitted.remove(); - Request request = new Request(null, p.hdr.getClientId(), p.hdr.getCxid(), p.hdr.getType(), null, null); - request.setTxn(p.rec); - request.setHdr(p.hdr); + Request request = new Request(p.hdr.getClientId(), p.hdr.getCxid(), p.hdr.getType(), p.hdr, p.rec, -1); request.setTxnDigest(p.digest); ozk.commitRequest(request); } |