Optimize DiscoveryNodeManager.refreshNodeInternal

prestodb · Oct 2, 2023 · a635c34 · a635c34
1 parent 93ac346
commit a635c34
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/presto-main/src/main/java/com/facebook/presto/metadata/DiscoveryNodeManager.java b/presto-main/src/main/java/com/facebook/presto/metadata/DiscoveryNodeManager.java
@@ -277,8 +277,9 @@ private synchronized void refreshNodesInternal()
     {
         // This is currently a blacklist.
         // TODO: make it a whitelist (a failure-detecting service selector) and maybe build in support for injecting this in airlift
+        Set<ServiceDescriptor> failed = failureDetector.getFailed();
         Set<ServiceDescriptor> services = serviceSelector.selectAllServices().stream()
-                .filter(service -> !failureDetector.getFailed().contains(service))
+                .filter(service -> !failed.contains(service))
                 .filter(filterRelevantNodes())
                 .collect(toImmutableSet());