Without pre-creating index, heavy write rates OOM with too many threads, closes #1081.
This commit is contained in:
parent
4c913693a9
commit
a8969cd672
|
@ -52,7 +52,7 @@ public class TransportIndicesAliasesAction extends TransportMasterNodeOperationA
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -58,7 +58,7 @@ public class TransportAnalyzeAction extends TransportSingleCustomOperationAction
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.INDEX;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected AnalyzeRequest newRequest() {
|
@Override protected AnalyzeRequest newRequest() {
|
||||||
|
|
|
@ -57,7 +57,7 @@ public class TransportClearIndicesCacheAction extends TransportBroadcastOperatio
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class TransportCloseIndexAction extends TransportMasterNodeOperationActio
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class TransportCreateIndexAction extends TransportMasterNodeOperationActi
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -60,7 +60,7 @@ public class TransportDeleteIndexAction extends TransportMasterNodeOperationActi
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -45,7 +45,7 @@ public class TransportIndicesExistsAction extends TransportMasterNodeOperationAc
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -57,7 +57,7 @@ public class TransportFlushAction extends TransportBroadcastOperationAction<Flus
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -54,7 +54,7 @@ public class TransportGatewaySnapshotAction extends TransportBroadcastOperationA
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -66,7 +66,7 @@ public class TransportDeleteMappingAction extends TransportMasterNodeOperationAc
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -52,7 +52,7 @@ public class TransportPutMappingAction extends TransportMasterNodeOperationActio
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class TransportOpenIndexAction extends TransportMasterNodeOperationAction
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -60,7 +60,7 @@ public class TransportOptimizeAction extends TransportBroadcastOperationAction<O
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MERGE;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -58,7 +58,7 @@ public class TransportRefreshAction extends TransportBroadcastOperationAction<Re
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -61,7 +61,7 @@ public class TransportIndicesSegmentsAction extends TransportBroadcastOperationA
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -47,7 +47,7 @@ public class TransportUpdateSettingsAction extends TransportMasterNodeOperationA
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class TransportDeleteIndexTemplateAction extends TransportMasterNodeOpera
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class TransportPutIndexTemplateAction extends TransportMasterNodeOperatio
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String executor() {
|
@Override protected String executor() {
|
||||||
return ThreadPool.Names.CACHED;
|
return ThreadPool.Names.MANAGEMENT;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected String transportAction() {
|
@Override protected String transportAction() {
|
||||||
|
|
Loading…
Reference in New Issue