Fix error message

elastic · Aug 20, 2018 · 5c097f3 · 5c097f3
1 parent 73fe46c
commit 5c097f3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java b/...ugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java
@@ -252,8 +252,10 @@ private ElasticsearchStatusException createUnlicensedError(
 
     private ElasticsearchStatusException createUnknownLicenseError(
             final String datafeedId, final List<String> remoteIndices, final Exception cause) {
-        final String remoteClusterQualifier = remoteIndices.size() == 1 ? "a remote cluster" : "remote clusters";
-        final String licenseTypeQualifier = remoteIndices.size() == 1 ? "" : "s";
+        final int numberOfRemoteClusters = RemoteClusterLicenseChecker.remoteClusterAliases(remoteIndices).size();
+        assert numberOfRemoteClusters > 0;
+        final String remoteClusterQualifier = numberOfRemoteClusters == 1 ? "a remote cluster" : "remote clusters";
+        final String licenseTypeQualifier = numberOfRemoteClusters == 1 ? "" : "s";
         final String message = String.format(
                 Locale.ROOT,
                 "cannot start datafeed [%s] as it uses indices on %s %s but the license type%s could not be verified",