test

server/src/internalClusterTest/java/org/opensearch/search/CoordinatorTimeoutIT.java

@@ -72,9 +72,7 @@ public void testTimeoutDuringQueryPhase() throws Exception {
             .setQuery(scriptQuery(new Script(ScriptType.INLINE, "mockscript", ScriptedBlockPlugin.SCRIPT_NAME, Collections.emptyMap())))
             .execute();
         awaitForBlock(plugins);
-        logger.info("begin to sleep for " + coordinatorTimeout.getMillis() + " ms");
         Thread.sleep(coordinatorTimeout.getMillis() + 100);
-        logger.info("wake up");
         disableBlocks(plugins);
         SearchResponse searchResponse = searchResponseFuture.get();
         assertEquals(1, searchResponse.getSuccessfulShards());

server/src/internalClusterTest/java/org/opensearch/search/basic/SearchWithRandomExceptionsIT.java

@@ -190,7 +190,7 @@ public void testRandomExceptions() throws IOException, InterruptedException, Exe
                 }
 
             } catch (SearchPhaseExecutionException ex) {
-                logger.info("expected SearchPhaseException: [{}]", ex.getMessage());
+                logger.info("expected SearchPhaseException: [{}]", ex);
             }
         }
 

server/src/main/java/org/opensearch/action/search/SearchRequest.java

@@ -279,7 +279,7 @@ public SearchRequest(StreamInput in) throws IOException {
         if (in.getVersion().onOrAfter(Version.V_2_12_0)) {
             phaseTook = in.readOptionalBoolean();
         }
-        if (in.getVersion().onOrAfter(Version.V_2_19_0)) {
+        if (in.getVersion().onOrAfter(Version.V_3_0_0)) {// TODO: Change if/when we backport to 2.x
             coordinatorTimeout = in.readOptionalTimeValue();
         }
     }
@@ -316,7 +316,7 @@ public void writeTo(StreamOutput out) throws IOException {
         if (out.getVersion().onOrAfter(Version.V_2_12_0)) {
             out.writeOptionalBoolean(phaseTook);
         }
-        if (out.getVersion().onOrAfter(Version.V_2_19_0)) {
+        if (out.getVersion().onOrAfter(Version.V_3_0_0)) {// TODO: Change if/when we backport to 2.x
             out.writeOptionalTimeValue(coordinatorTimeout);
         }
     }

test/framework/src/main/java/org/opensearch/common/util/MockBigArrays.java

@@ -64,7 +64,7 @@ public class MockBigArrays extends BigArrays {
      * Tracking allocations is useful when debugging a leak but shouldn't be enabled by default as this would also be very costly
      * since it creates a new Exception every time a new array is created.
      */
-    private static final boolean TRACK_ALLOCATIONS = false;
+    private static final boolean TRACK_ALLOCATIONS = true;
 
     private static final ConcurrentMap<Object, Object> ACQUIRED_ARRAYS = new ConcurrentHashMap<>();