diff --git a/server/src/main/java/org/opensearch/discovery/PeerFinder.java b/server/src/main/java/org/opensearch/discovery/PeerFinder.java
index 1d997c8cbabe8..3a88fc03e7ca0 100644
--- a/server/src/main/java/org/opensearch/discovery/PeerFinder.java
+++ b/server/src/main/java/org/opensearch/discovery/PeerFinder.java
@@ -442,7 +442,7 @@ public void onResponse(DiscoveryNode remoteNode) {
                 public void onFailure(Exception e) {
                     logger.debug(() -> new ParameterizedMessage("{} connection failed", Peer.this), e);
                     synchronized (mutex) {
-                        peersByAddress.remove(transportAddress);
+                        peersByAddress.remove(transportAddress, Peer.this);
                     }
                 }
             });