diff --git a/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java b/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java
index 2d5f27dd62..a7ea6aa22f 100644
--- a/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java
+++ b/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java
@@ -31,12 +31,15 @@ public void leaseManagerRejectsJobs() {
     DefaultLeaseManager defaultLeaseManager = new DefaultLeaseManager(settings, stateStore);
 
     defaultLeaseManager.borrow(getLeaseRequest(JobType.BATCH));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.INTERACTIVE)));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.STREAMING)));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.REFRESH)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.INTERACTIVE)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.STREAMING)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.REFRESH)));
   }
 
   @Test