summaryrefslogtreecommitdiff
path: root/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/AckRequestProcessor.java
diff options
context:
space:
mode:
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.java2
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");
}