Skip to content

Commit fa3a10c

Browse files
committed
Remove V_8_13_0 version checks
1 parent 58afdff commit fa3a10c

File tree

1 file changed

+2
-12
lines changed

1 file changed

+2
-12
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/DesiredNode.java

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111

1212
import org.elasticsearch.TransportVersion;
1313
import org.elasticsearch.TransportVersions;
14-
import org.elasticsearch.Version;
1514
import org.elasticsearch.cluster.node.DiscoveryNode;
1615
import org.elasticsearch.cluster.node.DiscoveryNodeRole;
1716
import org.elasticsearch.common.io.stream.StreamInput;
@@ -163,12 +162,7 @@ public static DesiredNode readFrom(StreamInput in) throws IOException {
163162
final var memory = ByteSizeValue.readFrom(in);
164163
final var storage = ByteSizeValue.readFrom(in);
165164
if (in.getTransportVersion().before(TransportVersions.REMOVE_DESIRED_NODE_VERSION)) {
166-
final String version;
167-
if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
168-
version = in.readOptionalString();
169-
} else {
170-
version = Version.readVersion(in).toString();
171-
}
165+
in.readOptionalString();
172166
}
173167
return new DesiredNode(settings, processors, processorsRange, memory, storage);
174168
}
@@ -187,11 +181,7 @@ public void writeTo(StreamOutput out) throws IOException {
187181
memory.writeTo(out);
188182
storage.writeTo(out);
189183
if (out.getTransportVersion().before(TransportVersions.REMOVE_DESIRED_NODE_VERSION)) {
190-
if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
191-
out.writeOptionalString(null);
192-
} else {
193-
Version.writeVersion(Version.CURRENT, out);
194-
}
184+
out.writeOptionalString(null);
195185
}
196186
}
197187

0 commit comments

Comments
 (0)