Execute Calcite PPL query in thread pool (#3508)

Signed-off-by: Lantao Jin <[email protected]>
Signed-off-by: xinyual <[email protected]>

Author: LantaoJin

opensearch/src/main/java/org/opensearch/sql/opensearch/executor/OpenSearchExecutionEngine.java

@@ -113,17 +113,19 @@ public ExplainResponseNode visitTableScan(
   @Override
   public void execute(
       RelNode rel, CalcitePlanContext context, ResponseListener<QueryResponse> listener) {
-    AccessController.doPrivileged(
-        (PrivilegedAction<Void>)
-            () -> {
-              try (PreparedStatement statement = OpenSearchRelRunners.run(context, rel)) {
-                ResultSet result = statement.executeQuery();
-                buildResultSet(result, rel.getRowType(), listener);
-                return null;
-              } catch (SQLException e) {
-                throw new RuntimeException(e);
-              }
-            });
+    client.schedule(
+        () ->
+            AccessController.doPrivileged(
+                (PrivilegedAction<Void>)
+                    () -> {
+                      try (PreparedStatement statement = OpenSearchRelRunners.run(context, rel)) {
+                        ResultSet result = statement.executeQuery();
+                        buildResultSet(result, rel.getRowType(), listener);
+                      } catch (SQLException e) {
+                        listener.onFailure(e);
+                      }
+                      return null;
+                    }));
   }
 
   private void buildResultSet(