Skip to content

Commit b9b7bd4

Browse files
committed
Adapt bwc versions after backporting #31045 to 6.3
1 parent 9bac2ae commit b9b7bd4

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

server/src/main/java/org/elasticsearch/persistent/PersistentTasksCustomMetaData.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ public PersistentTask(StreamInput in) throws IOException {
313313
id = in.readString();
314314
allocationId = in.readLong();
315315
taskName = in.readString();
316-
if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
316+
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
317317
params = (P) in.readNamedWriteable(PersistentTaskParams.class);
318318
} else {
319319
params = (P) in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -328,7 +328,7 @@ public void writeTo(StreamOutput out) throws IOException {
328328
out.writeString(id);
329329
out.writeLong(allocationId);
330330
out.writeString(taskName);
331-
if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
331+
if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
332332
out.writeNamedWriteable(params);
333333
} else {
334334
out.writeOptionalNamedWriteable(params);

server/src/main/java/org/elasticsearch/persistent/StartPersistentTaskAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public void readFrom(StreamInput in) throws IOException {
9393
super.readFrom(in);
9494
taskId = in.readString();
9595
taskName = in.readString();
96-
if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
96+
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
9797
params = in.readNamedWriteable(PersistentTaskParams.class);
9898
} else {
9999
params = in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -105,7 +105,7 @@ public void writeTo(StreamOutput out) throws IOException {
105105
super.writeTo(out);
106106
out.writeString(taskId);
107107
out.writeString(taskName);
108-
if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
108+
if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
109109
out.writeNamedWriteable(params);
110110
} else {
111111
out.writeOptionalNamedWriteable(params);

0 commit comments

Comments
 (0)