fix bug

keith-turner · Oct 4, 2024 · 027ad4a · 027ad4a
1 parent 5a16bfb
commit 027ad4a
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/core/src/main/java/org/apache/accumulo/core/rpc/clients/TServerClient.java b/core/src/main/java/org/apache/accumulo/core/rpc/clients/TServerClient.java
@@ -39,6 +39,7 @@
 import org.apache.accumulo.core.fate.zookeeper.ZooCache;
 import org.apache.accumulo.core.lock.ServiceLockData;
 import org.apache.accumulo.core.lock.ServiceLockData.ThriftService;
+import org.apache.accumulo.core.lock.ServiceLockPaths.AddressPredicate;
 import org.apache.accumulo.core.lock.ServiceLockPaths.ServiceLockPath;
 import org.apache.accumulo.core.rpc.ThriftUtil;
 import org.apache.accumulo.core.rpc.clients.ThriftClientTypes.Exec;
@@ -86,12 +87,12 @@ default Pair<String,C> getThriftServerConnection(Logger LOG, ThriftClientTypes<C
       // that the path is correct and the lock is held and will return the
       // correct one.
       HostAndPort hp = HostAndPort.fromString(debugHost);
-      serverPaths
-          .addAll(context.getServerPaths().getCompactor(rg -> true, addr -> addr.equals(hp), true));
       serverPaths.addAll(
-          context.getServerPaths().getScanServer(rg -> true, addr -> addr.equals(hp), true));
+          context.getServerPaths().getCompactor(rg -> true, AddressPredicate.exact(hp), true));
       serverPaths.addAll(
-          context.getServerPaths().getTabletServer(rg -> true, addr -> addr.equals(hp), true));
+          context.getServerPaths().getScanServer(rg -> true, AddressPredicate.exact(hp), true));
+      serverPaths.addAll(
+          context.getServerPaths().getTabletServer(rg -> true, AddressPredicate.exact(hp), true));
     } else {
       serverPaths.addAll(context.getServerPaths().getTabletServer(rg -> true, addr -> true, true));
       if (type == ThriftClientTypes.CLIENT) {