Update node list on workers

Some connectors require an active list of all worers on worker nodes. This commit restores this behavior which was recently removed.
trinodb · Jan 23, 2019 · 17112e0 · 17112e0
1 parent 14db5b5
commit 17112e0
Showing 1 changed file with 8 additions and 11 deletions.
diff --git a/presto-main/src/main/java/io/prestosql/metadata/DiscoveryNodeManager.java b/presto-main/src/main/java/io/prestosql/metadata/DiscoveryNodeManager.java
@@ -145,17 +145,14 @@ private static PrestoNode findCurrentNode(List<ServiceDescriptor> allServices, S
     @PostConstruct
     public void startPollingNodeStates()
     {
-        // poll worker states only on the coordinators
-        if (currentNode.isCoordinator()) {
-            nodeStateUpdateExecutor.scheduleWithFixedDelay(() -> {
-                try {
-                    pollWorkers();
-                }
-                catch (Exception e) {
-                    log.error(e, "Error polling state of nodes");
-                }
-            }, 5, 5, TimeUnit.SECONDS);
-        }
+        nodeStateUpdateExecutor.scheduleWithFixedDelay(() -> {
+            try {
+                pollWorkers();
+            }
+            catch (Exception e) {
+                log.error(e, "Error polling state of nodes");
+            }
+        }, 5, 5, TimeUnit.SECONDS);
         pollWorkers();
     }