diff options
Diffstat (limited to 'zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java')
-rw-r--r-- | zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java index 32eb8a818..f277dcdf3 100644 --- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java +++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java @@ -44,7 +44,7 @@ class AckRequestProcessor implements RequestProcessor { QuorumPeer self = leader.self; if (self != null) { request.logLatency(ServerMetrics.getMetrics().PROPOSAL_ACK_CREATION_LATENCY); - leader.processAck(self.getId(), request.zxid, null); + leader.processAck(self.getMyId(), request.zxid, null); } else { LOG.error("Null QuorumPeer"); } |