fix format

Signed-off-by: Peng Huo <[email protected]>
opensearch-project · Feb 6, 2024 · 671ca08 · 671ca08
1 parent 2cba3c8
commit 671ca08
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 13 deletions.
diff --git a/common/src/main/java/org/opensearch/sql/common/setting/Settings.java b/common/src/main/java/org/opensearch/sql/common/setting/Settings.java
@@ -47,7 +47,7 @@ public enum Key {
     SESSION_INACTIVITY_TIMEOUT_MILLIS(
         "plugins.query.executionengine.spark.session_inactivity_timeout_millis"),
 
-    /** Async query Settings **/
+    /** Async query Settings * */
     ASYNC_QUERY_ENABLED("plugins.query.executionengine.async_query.enabled");
 
     @Getter private final String keyValue;

diff --git a/integ-test/src/test/java/org/opensearch/sql/asyncquery/AsyncQueryIT.java b/integ-test/src/test/java/org/opensearch/sql/asyncquery/AsyncQueryIT.java
@@ -33,7 +33,7 @@ public void asyncQueryEnabledSettingsTest() throws IOException {
     String query = "select 1";
     Response response = null;
     try {
-      executeAsyncQueryToString (query);
+      executeAsyncQueryToString(query);
     } catch (ResponseException ex) {
       response = ex.getResponse();
     }
@@ -60,11 +60,15 @@ protected String executeAsyncQueryToString(String query) throws IOException {
   protected Request buildAsyncRequest(String query, String endpoint) {
     Request request = new Request("POST", endpoint);
     request.setJsonEntity(String.format(Locale.ROOT, "{\n" + "  \"query\": \"%s\"\n" + "}", query));
-    request.setJsonEntity(String.format(Locale.ROOT, "{\n" +
-        "  \"datasource\": \"mys3\",\n" +
-        "  \"lang\": \"sql\",\n" +
-        "  \"query\": \"%s\"\n" +
-        "}", query));
+    request.setJsonEntity(
+        String.format(
+            Locale.ROOT,
+            "{\n"
+                + "  \"datasource\": \"mys3\",\n"
+                + "  \"lang\": \"sql\",\n"
+                + "  \"query\": \"%s\"\n"
+                + "}",
+            query));
 
     RequestOptions.Builder restOptionsBuilder = RequestOptions.DEFAULT.toBuilder();
     restOptionsBuilder.addHeader("Content-Type", "application/json");

diff --git a/.../main/java/org/opensearch/sql/spark/transport/TransportCreateAsyncQueryRequestAction.java b/.../main/java/org/opensearch/sql/spark/transport/TransportCreateAsyncQueryRequestAction.java
@@ -53,9 +53,12 @@ protected void doExecute(
       ActionListener<CreateAsyncQueryActionResponse> listener) {
     try {
       if (!(Boolean) pluginSettings.getSettingValue(Settings.Key.ASYNC_QUERY_ENABLED)) {
-        listener.onFailure(new IllegalAccessException(String.format(Locale.ROOT, "%s setting is " +
-                "false",
-            Settings.Key.ASYNC_QUERY_ENABLED.getKeyValue())));
+        listener.onFailure(
+            new IllegalAccessException(
+                String.format(
+                    Locale.ROOT,
+                    "%s setting is " + "false",
+                    Settings.Key.ASYNC_QUERY_ENABLED.getKeyValue())));
         return;
       }
 

diff --git a/...t/java/org/opensearch/sql/spark/transport/TransportCreateAsyncQueryRequestActionTest.java b/...t/java/org/opensearch/sql/spark/transport/TransportCreateAsyncQueryRequestActionTest.java
@@ -56,7 +56,10 @@ public class TransportCreateAsyncQueryRequestActionTest {
   public void setUp() {
     action =
         new TransportCreateAsyncQueryRequestAction(
-            transportService, new ActionFilters(new HashSet<>()), jobExecutorService, pluginSettings);
+            transportService,
+            new ActionFilters(new HashSet<>()),
+            jobExecutorService,
+            pluginSettings);
   }
 
   @Test
@@ -125,7 +128,8 @@ public void asyncQueryDisabled() {
     Mockito.verify(actionListener).onFailure(exceptionArgumentCaptor.capture());
     Exception exception = exceptionArgumentCaptor.getValue();
     Assertions.assertTrue(exception instanceof IllegalAccessException);
-    Assertions.assertEquals("plugins.query.executionengine.async_query.enabled " +
-        "setting is false", exception.getMessage());
+    Assertions.assertEquals(
+        "plugins.query.executionengine.async_query.enabled " + "setting is false",
+        exception.getMessage());
   }
 }