Disable scroll cleaning.

Signed-off-by: Yury-Fridlyand <[email protected]>
Bit-Quill · Feb 8, 2023 · 9db17c3 · 9db17c3
1 parent 4cc76c3
commit 9db17c3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/opensearch/src/main/java/org/opensearch/sql/opensearch/client/OpenSearchNodeClient.java b/opensearch/src/main/java/org/opensearch/sql/opensearch/client/OpenSearchNodeClient.java
@@ -173,7 +173,7 @@ public Map<String, String> meta() {
 
   @Override
   public void cleanup(OpenSearchRequest request) {
-    request.clean(scrollId -> client.prepareClearScroll().addScrollId(scrollId).get());
+    request.clean(scrollId -> {}/* client.prepareClearScroll().addScrollId(scrollId).get() */);
   }
 
   @Override

diff --git a/opensearch/src/main/java/org/opensearch/sql/opensearch/client/OpenSearchRestClient.java b/opensearch/src/main/java/org/opensearch/sql/opensearch/client/OpenSearchRestClient.java
@@ -174,15 +174,15 @@ public Map<String, String> meta() {
 
   @Override
   public void cleanup(OpenSearchRequest request) {
-    request.clean(scrollId -> {
+    request.clean(scrollId -> {/*
       try {
         ClearScrollRequest clearRequest = new ClearScrollRequest();
         clearRequest.addScrollId(scrollId);
         client.clearScroll(clearRequest, RequestOptions.DEFAULT);
       } catch (IOException e) {
         throw new IllegalStateException(
             "Failed to clean up resources for search request " + request, e);
-      }
+      }*/
     });
 
   }