add sleep in ConcurrentQueryPhaseSearcher to prevent memory leak

Signed-off-by: Neetika Singhal <neetiks@amazon.com>
neetikasinghal · Dec 29, 2023 · f38531a · f38531a
1 parent 60b2265
commit f38531a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/src/main/java/org/opensearch/search/query/ConcurrentQueryPhaseSearcher.java b/server/src/main/java/org/opensearch/search/query/ConcurrentQueryPhaseSearcher.java
@@ -82,6 +82,11 @@ private static boolean searchWithCollectorManager(
             final ReduceableSearchResult result = searcher.search(query, collectorManager);
             result.reduce(queryResult);
         } catch (RuntimeException re) {
+            try {
+                Thread.sleep(5000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
             rethrowCauseIfPossible(re, searchContext);
         }
         if (searchContext.isSearchTimedOut()) {