changed persistent task name to be of similar structure as the others

elastic · May 31, 2018 · e05884b · e05884b
1 parent 7e811c7
commit e05884b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...luster-with-security/src/test/java/org/elasticsearch/xpack/ccr/FollowIndexSecurityIT.java b/...luster-with-security/src/test/java/org/elasticsearch/xpack/ccr/FollowIndexSecurityIT.java
@@ -125,7 +125,7 @@ private int countCcrNodeTasks() throws IOException {
         for (Map.Entry<?, ?> entry : nodeTasks.entrySet()) {
             Map<?, ?> nodeTask = (Map<?, ?>) entry.getValue();
             String action = (String) nodeTask.get("action");
-            if (action.startsWith("shard_follow")) {
+            if (action.startsWith("xpack/ccr/shard_follow_task")) {
                 numNodeTasks++;
             }
         }

diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowTask.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowTask.java
@@ -25,7 +25,7 @@
 
 public class ShardFollowTask implements PersistentTaskParams {
 
-    public static final String NAME = "shard_follow";
+    public static final String NAME = "xpack/ccr/shard_follow_task";
 
     // list of headers that will be stored when a job is created
     public static final Set<String> HEADER_FILTERS =