remove usages of version

Signed-off-by: Rishikesh1159 <[email protected]>
Rishikesh1159 · Mar 16, 2023 · 5631c93 · 5631c93
1 parent 3555a7d
commit 5631c93
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/server/src/main/java/org/opensearch/action/admin/cluster/node/stats/NodeStats.java b/server/src/main/java/org/opensearch/action/admin/cluster/node/stats/NodeStats.java
@@ -189,7 +189,7 @@ public NodeStats(StreamInput in) throws IOException {
         } else {
             weightedRoutingStats = null;
         }
-        if (in.getVersion().onOrAfter(Version.V_2_7_0) && FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT)) {
+        if (in.getVersion().onOrAfter(Version.V_2_6_0) && FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT)) {
             fileCacheStats = in.readOptionalWriteable(FileCacheStats::new);
         } else {
             fileCacheStats = null;
@@ -409,7 +409,7 @@ public void writeTo(StreamOutput out) throws IOException {
         if (out.getVersion().onOrAfter(Version.V_2_6_0)) {
             out.writeOptionalWriteable(weightedRoutingStats);
         }
-        if (out.getVersion().onOrAfter(Version.V_2_7_0) && FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT)) {
+        if (out.getVersion().onOrAfter(Version.V_2_6_0) && FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT)) {
             out.writeOptionalWriteable(fileCacheStats);
         }
     }

diff --git a/server/src/main/java/org/opensearch/monitor/fs/FsInfo.java b/server/src/main/java/org/opensearch/monitor/fs/FsInfo.java
@@ -97,7 +97,7 @@ public Path(StreamInput in) throws IOException {
             total = in.readLong();
             free = in.readLong();
             available = in.readLong();
-            if (FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT) && in.getVersion().onOrAfter(Version.V_2_7_0)) {
+            if (FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT) && in.getVersion().onOrAfter(Version.V_2_6_0)) {
                 fileCacheReserved = in.readLong();
                 fileCacheUtilized = in.readLong();
             }
@@ -111,7 +111,7 @@ public void writeTo(StreamOutput out) throws IOException {
             out.writeLong(total);
             out.writeLong(free);
             out.writeLong(available);
-            if (FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT) && out.getVersion().onOrAfter(Version.V_2_7_0)) {
+            if (FeatureFlags.isEnabled(FeatureFlags.SEARCHABLE_SNAPSHOT) && out.getVersion().onOrAfter(Version.V_2_6_0)) {
                 out.writeLong(fileCacheReserved);
                 out.writeLong(fileCacheUtilized);
             }