diff --git a/core/src/main/java/org/elasticsearch/action/search/RemoteClusterService.java b/core/src/main/java/org/elasticsearch/action/search/RemoteClusterService.java index 1e01a6be19b..c25eeaa7340 100644 --- a/core/src/main/java/org/elasticsearch/action/search/RemoteClusterService.java +++ b/core/src/main/java/org/elasticsearch/action/search/RemoteClusterService.java @@ -66,7 +66,7 @@ import java.util.function.Predicate; public final class RemoteClusterService extends AbstractComponent implements Closeable { /** - * A list of initial seed nodes to discover eligibale nodes from the remote cluster + * A list of initial seed nodes to discover eligible nodes from the remote cluster */ //TODO this should be an affix settings? public static final Setting REMOTE_CLUSTERS_SEEDS = Setting.groupSetting("search.remote.seeds.", @@ -87,9 +87,10 @@ public final class RemoteClusterService extends AbstractComponent implements Clo Setting.positiveTimeSetting("search.remote.initial_connect_timeout", TimeValue.timeValueSeconds(30), Setting.Property.NodeScope); /** - * The name of a node attribute to filter out nodes that should not be connected to in the remote cluster. + * The name of a node attribute to select nodes that should be connected to in the remote cluster. * For instance a node can be configured with node.node_attr.gateway: true in order to be eligible as a gateway node between - * clusters. In that case search.remote.node_attribute: gateway can be used to filter out other nodes in the remote cluster + * clusters. In that case search.remote.node_attribute: gateway can be used to filter out other nodes in the remote cluster. + * The value of the setting is expected to be a boolean, for nodes that can become gateways, false otherwise. */ public static final Setting REMOTE_NODE_ATTRIBUTE = Setting.simpleString("search.remote.node_attribute", Setting.Property.NodeScope); @@ -326,7 +327,6 @@ public final class RemoteClusterService extends AbstractComponent implements Clo } static void validateRemoteClustersSeeds(Settings settings) { - //TODO do we need a static whitelist like in reindex from remote? for (String clusterName : settings.names()) { String[] remoteHosts = settings.getAsArray(clusterName); if (remoteHosts.length == 0) {