fix format

Signed-off-by: Peng Huo <penghuo@gmail.com>
penghuo · Oct 13, 2023 · ff02f28 · ff02f28
1 parent 8d4dc76
commit ff02f28
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/spark/src/test/java/org/opensearch/sql/spark/execution/session/InteractiveSessionTest.java b/spark/src/test/java/org/opensearch/sql/spark/execution/session/InteractiveSessionTest.java
@@ -57,7 +57,11 @@ public void openCloseSession() {
 
     // open session
     TestSession testSession = testSession(session, stateStore);
-    testSession.open(new CreateSessionRequest(startJobRequest, "datasource")).assertSessionState(NOT_STARTED).assertAppId("appId").assertJobId("jobId");
+    testSession
+        .open(new CreateSessionRequest(startJobRequest, "datasource"))
+        .assertSessionState(NOT_STARTED)
+        .assertAppId("appId")
+        .assertJobId("jobId");
     emrsClient.startJobRunCalled(1);
 
     // close session
@@ -83,7 +87,9 @@ public void openSessionFailedConflict() {
             .serverlessClient(emrsClient)
             .build();
     IllegalStateException exception =
-        assertThrows(IllegalStateException.class, () -> duplicateSession.open(new CreateSessionRequest(startJobRequest, "datasource")));
+        assertThrows(
+            IllegalStateException.class,
+            () -> duplicateSession.open(new CreateSessionRequest(startJobRequest, "datasource")));
     assertEquals("session already exist. sessionId=duplicate-session-id", exception.getMessage());
   }