Use TransportVersion V9

elastic · Feb 4, 2025 · 9c02c10 · 9c02c10
1 parent 4fba814
commit 9c02c10
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/DesiredNode.java b/server/src/main/java/org/elasticsearch/cluster/metadata/DesiredNode.java
@@ -162,8 +162,7 @@ public static DesiredNode readFrom(StreamInput in) throws IOException {
         }
         final var memory = ByteSizeValue.readFrom(in);
         final var storage = ByteSizeValue.readFrom(in);
-        // if (in.getTransportVersion().before(TransportVersion.V_9_00_0)) {
-        if (true) {
+        if (in.getTransportVersion().before(TransportVersions.ELASTICSEARCH_9_0)) {
             final String version;
             if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
                 version = in.readOptionalString();
@@ -187,8 +186,7 @@ public void writeTo(StreamOutput out) throws IOException {
         }
         memory.writeTo(out);
         storage.writeTo(out);
-        // if (out.getTransportVersion().before(TransportVersion.V_9_00_0)) {
-        if (true) {
+        if (out.getTransportVersion().before(TransportVersions.ELASTICSEARCH_9_0)) {
             if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
                 out.writeOptionalString(null);
             } else {