Change RTS stats version check to V_2_10_0

Signed-off-by: Bhumika Saini <sabhumik@amazon.com>
BhumikaSaini-Amazon · Sep 7, 2023 · 7f15b9c · 7f15b9c
1 parent 579e8d9
commit 7f15b9c
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogStats.java b/server/src/main/java/org/opensearch/index/translog/TranslogStats.java
@@ -71,9 +71,7 @@ public TranslogStats(StreamInput in) throws IOException {
         uncommittedOperations = in.readVInt();
         uncommittedSizeInBytes = in.readVLong();
         earliestLastModifiedAge = in.readVLong();
-        // TODO: remoteTranslogStats = in.getVersion().onOrAfter(Version.V_2_10_0) ? in.readOptionalWriteable(RemoteTranslogStats::new) :
-        // new RemoteTranslogStats();
-        remoteTranslogStats = in.getVersion().onOrAfter(Version.CURRENT)
+        remoteTranslogStats = in.getVersion().onOrAfter(Version.V_2_10_0)
             ? in.readOptionalWriteable(RemoteTranslogStats::new)
             : new RemoteTranslogStats();
     }
@@ -184,8 +182,7 @@ public void writeTo(StreamOutput out) throws IOException {
         out.writeVInt(uncommittedOperations);
         out.writeVLong(uncommittedSizeInBytes);
         out.writeVLong(earliestLastModifiedAge);
-        // TODO: if (out.getVersion().onOrAfter(Version.V_2_10_0)) {
-        if (out.getVersion().onOrAfter(Version.CURRENT)) {
+        if (out.getVersion().onOrAfter(Version.V_2_10_0)) {
             out.writeOptionalWriteable(remoteTranslogStats);
         }
     }