diff --git a/src/main/java/org/elasticsearch/action/admin/indices/get/TransportGetIndexAction.java b/src/main/java/org/elasticsearch/action/admin/indices/get/TransportGetIndexAction.java index 4a0bb73dfba..6c0f1271378 100644 --- a/src/main/java/org/elasticsearch/action/admin/indices/get/TransportGetIndexAction.java +++ b/src/main/java/org/elasticsearch/action/admin/indices/get/TransportGetIndexAction.java @@ -80,7 +80,7 @@ public class TransportGetIndexAction extends TransportClusterInfoAction> mappingsResult = ImmutableOpenMap.of(); ImmutableOpenMap> aliasesResult = ImmutableOpenMap.of(); ImmutableOpenMap settings = ImmutableOpenMap.of(); - Feature[] features = request.featuresAsEnums(); + Feature[] features = request.features(); boolean doneAliases = false; boolean doneMappings = false; boolean doneSettings = false; diff --git a/src/main/java/org/elasticsearch/action/admin/indices/mapping/get/GetFieldMappingsRequest.java b/src/main/java/org/elasticsearch/action/admin/indices/mapping/get/GetFieldMappingsRequest.java index fe812edd008..3ebf3273527 100644 --- a/src/main/java/org/elasticsearch/action/admin/indices/mapping/get/GetFieldMappingsRequest.java +++ b/src/main/java/org/elasticsearch/action/admin/indices/mapping/get/GetFieldMappingsRequest.java @@ -23,11 +23,9 @@ import org.elasticsearch.action.ActionRequest; import org.elasticsearch.action.ActionRequestValidationException; import org.elasticsearch.action.IndicesRequest; import org.elasticsearch.action.support.IndicesOptions; -import org.elasticsearch.action.support.master.MasterNodeOperationRequest; import org.elasticsearch.common.Strings; import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; -import org.elasticsearch.common.unit.TimeValue; import java.io.IOException; @@ -49,15 +47,6 @@ public class GetFieldMappingsRequest extends ActionRequest { @Override public void readFrom(StreamInput in) throws IOException { super.readFrom(in); - if (in.getVersion().before(Version.V_1_2_0)) { - in.readByte(); // backward comp. for operation threading - } scrollId = in.readString(); if (in.readBoolean()) { scroll = readScroll(in); @@ -112,9 +108,6 @@ public class SearchScrollRequest extends ActionRequest { @Override public void writeTo(StreamOutput out) throws IOException { super.writeTo(out); - if (out.getVersion().before(Version.V_1_2_0)) { - out.writeByte((byte) 2); // operation threading - } out.writeString(scrollId); if (scroll == null) { out.writeBoolean(false); diff --git a/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastOperationRequest.java b/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastOperationRequest.java index 5910c10ba37..ed7b68139a8 100644 --- a/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastOperationRequest.java +++ b/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastOperationRequest.java @@ -19,7 +19,6 @@ package org.elasticsearch.action.support.broadcast; -import org.elasticsearch.Version; import org.elasticsearch.action.ActionRequest; import org.elasticsearch.action.ActionRequestValidationException; import org.elasticsearch.action.IndicesRequest; @@ -89,9 +88,6 @@ public abstract class BroadcastOperationRequest implemen private volatile ImmutableList zenPings = ImmutableList.of(); - // here for backward comp. with discovery plugins - public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService, - ElectMasterService electMasterService, @Nullable Set unicastHostsProviders) { - this(settings, threadPool, transportService, clusterName, networkService, Version.CURRENT, electMasterService, unicastHostsProviders); - } - @Inject public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService, Version version, ElectMasterService electMasterService, @Nullable Set unicastHostsProviders) { @@ -74,19 +68,6 @@ public class ZenPingService extends AbstractLifecycleComponent implemen return this.zenPings; } - public void zenPings(ImmutableList pings) { - this.zenPings = pings; - if (lifecycle.started()) { - for (ZenPing zenPing : zenPings) { - zenPing.start(); - } - } else if (lifecycle.stopped()) { - for (ZenPing zenPing : zenPings) { - zenPing.stop(); - } - } - } - @Override public void setPingContextProvider(PingContextProvider contextProvider) { if (lifecycle.started()) { diff --git a/src/main/java/org/elasticsearch/rest/action/explain/RestExplainAction.java b/src/main/java/org/elasticsearch/rest/action/explain/RestExplainAction.java index 386c0eda6a2..0ce02a36f41 100644 --- a/src/main/java/org/elasticsearch/rest/action/explain/RestExplainAction.java +++ b/src/main/java/org/elasticsearch/rest/action/explain/RestExplainAction.java @@ -106,10 +106,9 @@ public class RestExplainAction extends BaseRestHandler { @Override public RestResponse buildResponse(ExplainResponse response, XContentBuilder builder) throws Exception { builder.startObject(); - //null checks for bw comp, since we only added in 1.4 index, type and id to ExplainResponse - builder.field(Fields._INDEX, response.getIndex() != null ? response.getIndex() : explainRequest.index()) - .field(Fields._TYPE, response.getType() != null ? response.getType() : explainRequest.type()) - .field(Fields._ID, response.getId() != null ? response.getId() : explainRequest.id()) + builder.field(Fields._INDEX, response.getIndex()) + .field(Fields._TYPE, response.getType()) + .field(Fields._ID, response.getId()) .field(Fields.MATCHED, response.isMatch()); if (response.hasExplanation()) {