Skip to content

Commit 167b9b3

Browse files
committed
Adapt bwc versions after backporting #31045 to 6.3
1 parent 526f906 commit 167b9b3

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
@@ -86,7 +86,7 @@ public void readFrom(StreamInput in) throws IOException {
8686
super.readFrom(in);
8787
taskId = in.readString();
8888
taskName = in.readString();
89-
if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
89+
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
9090
params = in.readNamedWriteable(PersistentTaskParams.class);
9191
} else {
9292
params = in.readOptionalNamedWriteable(PersistentTaskParams.class);
@@ -98,7 +98,7 @@ public void writeTo(StreamOutput out) throws IOException {
9898
super.writeTo(out);
9999
out.writeString(taskId);
100100
out.writeString(taskName);
101-
if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
101+
if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
102102
out.writeNamedWriteable(params);
103103
} else {
104104
out.writeOptionalNamedWriteable(params);

0 commit comments

Comments
 (0)