Adapt bwc versions after backporting #31045 to 6.3

elastic · Jun 4, 2018 · 1e5dc50 · 1e5dc50
1 parent 4a19118
commit 1e5dc50
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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 PersistentTask(StreamInput in) throws IOException {
             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_3_0)) {
                 params = (P) in.readNamedWriteable(PersistentTaskParams.class);
             } else {
                 params = (P) in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -328,7 +328,7 @@ public void writeTo(StreamOutput out) throws IOException {
             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_3_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
@@ -93,7 +93,7 @@ public void readFrom(StreamInput in) throws IOException {
             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_3_0)) {
                 params = in.readNamedWriteable(PersistentTaskParams.class);
             } else {
                 params = in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -105,7 +105,7 @@ public void writeTo(StreamOutput out) throws IOException {
             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_3_0)) {
                 out.writeNamedWriteable(params);
             } else {
                 out.writeOptionalNamedWriteable(params);