diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryExecutorServiceImplSpecTest.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryExecutorServiceImplSpecTest.java
index 452528b319..54bd253661 100644
--- a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryExecutorServiceImplSpecTest.java
+++ b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryExecutorServiceImplSpecTest.java
@@ -470,9 +470,10 @@ public void submitQueryInInvalidSessionWillCreateNewSession() {
 
     // 1. create async query with invalid sessionId
     SessionId invalidSessionId = SessionId.newSessionId(DATASOURCE);
-    CreateAsyncQueryResponse asyncQuery = asyncQueryExecutorService.createAsyncQuery(
-        new CreateAsyncQueryRequest(
-            "select 1", DATASOURCE, LangType.SQL, invalidSessionId.getSessionId()));
+    CreateAsyncQueryResponse asyncQuery =
+        asyncQueryExecutorService.createAsyncQuery(
+            new CreateAsyncQueryRequest(
+                "select 1", DATASOURCE, LangType.SQL, invalidSessionId.getSessionId()));
     assertNotNull(asyncQuery.getSessionId());
     assertNotEquals(invalidSessionId.getSessionId(), asyncQuery.getSessionId());
   }