diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java index 2f2ca8f7dd..dc840b00c9 100644 --- a/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java +++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java @@ -112,8 +112,8 @@ private static class RequestMap { this.resource = new RequestLimits(elementLimit, megabyteLimit); this.raftServerMetrics = raftServerMetrics; - raftServerMetrics.addNumPendingRequestsGauge(resource::getElementCount); - raftServerMetrics.addNumPendingRequestsMegaByteSize(resource::getMegaByteSize); + raftServerMetrics.addNumPendingRequestsGauge(() -> resource.getElementCount()); + raftServerMetrics.addNumPendingRequestsMegaByteSize(() -> resource.getMegaByteSize()); } Permit tryAcquire(Message message) {