Removed testDeleteAllPitReaderContexts test

Signed-off-by: Ajay Kumar Movva <[email protected]>

Author: Ajay Kumar Movva

server/src/main/java/org/opensearch/index/search/stats/SearchStats.java

@@ -32,6 +32,7 @@
 
 package org.opensearch.index.search.stats;
 
+import org.opensearch.Version;
 import org.opensearch.common.Nullable;
 import org.opensearch.common.Strings;
 import org.opensearch.common.io.stream.StreamInput;
@@ -140,9 +141,11 @@ private Stats(StreamInput in) throws IOException {
             suggestTimeInMillis = in.readVLong();
             suggestCurrent = in.readVLong();
 
-            pitCount = in.readVLong();
-            pitTimeInMillis = in.readVLong();
-            pitCurrent = in.readVLong();
+            if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
+                pitCount = in.readVLong();
+                pitTimeInMillis = in.readVLong();
+                pitCurrent = in.readVLong();
+            }
         }
 
         public void add(Stats stats) {
@@ -289,9 +292,11 @@ public void writeTo(StreamOutput out) throws IOException {
             out.writeVLong(suggestTimeInMillis);
             out.writeVLong(suggestCurrent);
 
-            out.writeVLong(pitCount);
-            out.writeVLong(pitTimeInMillis);
-            out.writeVLong(pitCurrent);
+            if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
+                out.writeVLong(pitCount);
+                out.writeVLong(pitTimeInMillis);
+                out.writeVLong(pitCurrent);
+            }
         }
 
         @Override

server/src/test/java/org/opensearch/search/PitMultiNodeTests.java

@@ -344,6 +344,7 @@ public void validatePitStats(String index, long expectedPitCurrent, long expecte
         assertEquals(expectedPitCurrent, pitCurrent);
         assertEquals(expectedOpenContexts, openContexts);
     }
+
     public void testGetAllPits() throws Exception {
         client().admin().indices().prepareCreate("index1").get();
         CreatePitRequest request = new CreatePitRequest(TimeValue.timeValueDays(1), true);

server/src/test/java/org/opensearch/search/SearchServiceTests.java

@@ -1455,21 +1455,6 @@ public void testDeletePitReaderContext() throws ExecutionException, InterruptedE
         validatePitStats("index", 0, 1, 0);
     }
 
-    public void testDeleteAllPitReaderContexts() throws ExecutionException, InterruptedException {
-        createIndex("index");
-        SearchService searchService = getInstanceFromNode(SearchService.class);
-        PlainActionFuture<ShardSearchContextId> future = new PlainActionFuture<>();
-        searchService.createPitReaderContext(new ShardId(resolveIndex("index"), 0), TimeValue.timeValueMinutes(between(1, 10)), future);
-        future.actionGet();
-        searchService.createPitReaderContext(new ShardId(resolveIndex("index"), 0), TimeValue.timeValueMinutes(between(1, 10)), future);
-        future.actionGet();
-        assertThat(searchService.getActiveContexts(), equalTo(2));
-        validatePitStats("index", 2, 0, 0);
-        searchService.freeAllPitContexts();
-        assertThat(searchService.getActiveContexts(), equalTo(0));
-        validatePitStats("index", 0, 2, 0);
-    }
-
     public void testPitContextMaxKeepAlive() {
         createIndex("index");
         SearchService searchService = getInstanceFromNode(SearchService.class);