diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/alias/TransportIndicesAliasesAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/alias/TransportIndicesAliasesAction.java index 4f8ff1b14f7..8c426d5d4ac 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/alias/TransportIndicesAliasesAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/alias/TransportIndicesAliasesAction.java @@ -52,7 +52,7 @@ public class TransportIndicesAliasesAction extends TransportMasterNodeOperationA } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/analyze/TransportAnalyzeAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/analyze/TransportAnalyzeAction.java index ba401d58d21..ac27e391f75 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/analyze/TransportAnalyzeAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/analyze/TransportAnalyzeAction.java @@ -58,7 +58,7 @@ public class TransportAnalyzeAction extends TransportSingleCustomOperationAction } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.INDEX; } @Override protected AnalyzeRequest newRequest() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/cache/clear/TransportClearIndicesCacheAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/cache/clear/TransportClearIndicesCacheAction.java index 7ed18f27f70..be8aa573baa 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/cache/clear/TransportClearIndicesCacheAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/cache/clear/TransportClearIndicesCacheAction.java @@ -57,7 +57,7 @@ public class TransportClearIndicesCacheAction extends TransportBroadcastOperatio } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java index 132d067935c..9e9003a6373 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java @@ -51,7 +51,7 @@ public class TransportCloseIndexAction extends TransportMasterNodeOperationActio } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/create/TransportCreateIndexAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/create/TransportCreateIndexAction.java index 8626b42636b..b6e6550430c 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/create/TransportCreateIndexAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/create/TransportCreateIndexAction.java @@ -51,7 +51,7 @@ public class TransportCreateIndexAction extends TransportMasterNodeOperationActi } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/delete/TransportDeleteIndexAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/delete/TransportDeleteIndexAction.java index cf680f6be7a..af401780003 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/delete/TransportDeleteIndexAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/delete/TransportDeleteIndexAction.java @@ -60,7 +60,7 @@ public class TransportDeleteIndexAction extends TransportMasterNodeOperationActi } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/exists/TransportIndicesExistsAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/exists/TransportIndicesExistsAction.java index 7ab2c279216..6a783dca630 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/exists/TransportIndicesExistsAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/exists/TransportIndicesExistsAction.java @@ -45,7 +45,7 @@ public class TransportIndicesExistsAction extends TransportMasterNodeOperationAc } @Override protected String executor() { - return ThreadPool.Names.CACHED; + return ThreadPool.Names.MANAGEMENT; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/flush/TransportFlushAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/flush/TransportFlushAction.java index a184b4536f7..bbcf1c80fb0 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/flush/TransportFlushAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/flush/TransportFlushAction.java @@ -57,7 +57,7 @@ public class TransportFlushAction extends TransportBroadcastOperationAction