From ccb78c2fdf92d0d0eb09640d8e3e3491c6d474fe Mon Sep 17 00:00:00 2001
From: Boaz Leskes <b.leskes@gmail.com>
Date: Sun, 3 Jun 2018 21:55:34 +0200
Subject: [PATCH] Adapt bwc versions after backporting #31045 to 6.x

---
 .../persistent/PersistentTasksCustomMetaData.java             | 4 ++--
 .../elasticsearch/persistent/StartPersistentTaskAction.java   | 4 ++--
 .../test/java/org/elasticsearch/cluster/ClusterStateIT.java   | 2 --
 3 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/server/src/main/java/org/elasticsearch/persistent/PersistentTasksCustomMetaData.java b/server/src/main/java/org/elasticsearch/persistent/PersistentTasksCustomMetaData.java
index 4b1ba3e11e3..3dc9d6e15ec 100644
--- a/server/src/main/java/org/elasticsearch/persistent/PersistentTasksCustomMetaData.java
+++ b/server/src/main/java/org/elasticsearch/persistent/PersistentTasksCustomMetaData.java
@@ -313,7 +313,7 @@ public final class PersistentTasksCustomMetaData extends AbstractNamedDiffable<M
             id = in.readString();
             allocationId = in.readLong();
             taskName = in.readString();
-            if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+            if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
                 params = (P) in.readNamedWriteable(PersistentTaskParams.class);
             } else {
                 params = (P) in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -328,7 +328,7 @@ public final class PersistentTasksCustomMetaData extends AbstractNamedDiffable<M
             out.writeString(id);
             out.writeLong(allocationId);
             out.writeString(taskName);
-            if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+            if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
                 out.writeNamedWriteable(params);
             } else {
                 out.writeOptionalNamedWriteable(params);
diff --git a/server/src/main/java/org/elasticsearch/persistent/StartPersistentTaskAction.java b/server/src/main/java/org/elasticsearch/persistent/StartPersistentTaskAction.java
index 2a1a59d9b08..9df93154983 100644
--- a/server/src/main/java/org/elasticsearch/persistent/StartPersistentTaskAction.java
+++ b/server/src/main/java/org/elasticsearch/persistent/StartPersistentTaskAction.java
@@ -86,7 +86,7 @@ public class StartPersistentTaskAction extends Action<StartPersistentTaskAction.
             super.readFrom(in);
             taskId = in.readString();
             taskName = in.readString();
-            if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+            if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
                 params = in.readNamedWriteable(PersistentTaskParams.class);
             } else {
                 params = in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -98,7 +98,7 @@ public class StartPersistentTaskAction extends Action<StartPersistentTaskAction.
             super.writeTo(out);
             out.writeString(taskId);
             out.writeString(taskName);
-            if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+            if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
                 out.writeNamedWriteable(params);
             } else {
                 out.writeOptionalNamedWriteable(params);
diff --git a/server/src/test/java/org/elasticsearch/cluster/ClusterStateIT.java b/server/src/test/java/org/elasticsearch/cluster/ClusterStateIT.java
index 2bf56e88814..fc917d60dee 100644
--- a/server/src/test/java/org/elasticsearch/cluster/ClusterStateIT.java
+++ b/server/src/test/java/org/elasticsearch/cluster/ClusterStateIT.java
@@ -33,7 +33,6 @@ import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.io.stream.Writeable;
-import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.xcontent.NamedXContentRegistry;
 import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.common.xcontent.XContentParser;
@@ -43,7 +42,6 @@ import org.elasticsearch.plugins.Plugin;
 import org.elasticsearch.script.ScriptService;
 import org.elasticsearch.test.ESIntegTestCase;
 import org.elasticsearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TcpTransport;
 import org.elasticsearch.watcher.ResourceWatcherService;
 
 import java.io.IOException;