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.
@@ -145,8 +145,6 @@ public final class DiscoveryNodeManager
@PostConstruct
public void startPollingNodeStates()
{
- // poll worker states only on the coordinators
- if (currentNode.isCoordinator()) {
nodeStateUpdateExecutor.scheduleWithFixedDelay(() -> {
try {
pollWorkers();
@@ -155,7 +153,6 @@ public final class DiscoveryNodeManager
log.error(e, "Error polling state of nodes");
}
}, 5, 5, TimeUnit.SECONDS);
- }
pollWorkers();
}
