[Remote Store] Update version check for Remote Translog Store upload …

…flow stats in nodes stats API (opensearch-project#9754) Signed-off-by: Bhumika Saini <[email protected]> Signed-off-by: Ivan Brusic <[email protected]>
brusic · Sep 25, 2023 · 796b372 · 796b372
1 parent 410b57d
commit 796b372
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);
         }
     }