diff --git a/priam/src/main/java/com/netflix/priam/identity/token/TokenRetrieverUtils.java b/priam/src/main/java/com/netflix/priam/identity/token/TokenRetrieverUtils.java index b7b6ee07e..77fe26898 100644 --- a/priam/src/main/java/com/netflix/priam/identity/token/TokenRetrieverUtils.java +++ b/priam/src/main/java/com/netflix/priam/identity/token/TokenRetrieverUtils.java @@ -39,7 +39,7 @@ public static InferredTokenOwnership inferTokenOwnerFromGossip( // Avoid other regions instances to avoid communication over public ip address. List eligibleInstances = allIds.stream() - .filter(priamInstance -> !priamInstance.getToken().equalsIgnoreCase(token)) + .filter(priamInstance -> !token.equalsIgnoreCase(priamInstance.getToken())) .filter(priamInstance -> priamInstance.getDC().equalsIgnoreCase(dc)) .collect(Collectors.toList()); // We want to get IP from min 1, max 3 instances to ensure we are not relying on