honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update version of TaskInfo header serialization after backport 

Update the serialization version after backporting #27764 to 6.x.
This commit is contained in:
Igor Motov 2018-01-14 19:20:32 -05:00
parent fbb840b5c8
commit aec0c0f9b6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/main/java/org/elasticsearch/tasks/TaskInfo.java
View File

@ -97,7 +97,7 @@ public final class TaskInfo implements Writeable, ToXContentFragment {
runningTimeNanos = in.readLong(); runningTimeNanos = in.readLong();
cancellable = in.readBoolean(); cancellable = in.readBoolean();
parentTaskId = TaskId.readFromStream(in); parentTaskId = TaskId.readFromStream(in);
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) { if (in.getVersion().onOrAfter(Version.V_6_2_0)) {
headers = in.readMap(StreamInput::readString, StreamInput::readString); headers = in.readMap(StreamInput::readString, StreamInput::readString);
} else { } else {
headers = Collections.emptyMap(); headers = Collections.emptyMap();
@ -115,7 +115,7 @@ public final class TaskInfo implements Writeable, ToXContentFragment {
out.writeLong(runningTimeNanos); out.writeLong(runningTimeNanos);
out.writeBoolean(cancellable); out.writeBoolean(cancellable);
parentTaskId.writeTo(out); parentTaskId.writeTo(out);
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) { if (out.getVersion().onOrAfter(Version.V_6_2_0)) {
out.writeMap(headers, StreamOutput::writeString, StreamOutput::writeString); out.writeMap(headers, StreamOutput::writeString, StreamOutput::writeString);
} }
} }