Reformat code

Signed-off-by: Tomoyuki Morita <[email protected]>
opensearch-project · Nov 13, 2024 · 0cfc9e2 · 0cfc9e2
1 parent dba09c4
commit 0cfc9e2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/async-query-core/src/main/java/org/opensearch/sql/spark/dispatcher/BatchQueryHandler.java b/async-query-core/src/main/java/org/opensearch/sql/spark/dispatcher/BatchQueryHandler.java
@@ -77,7 +77,8 @@ public String cancelJob(
   }
 
   /**
-   * This method allows RefreshQueryHandler to override the job type when calling leaseManager.borrow.
+   * This method allows RefreshQueryHandler to override the job type when calling
+   * leaseManager.borrow.
    */
   protected void borrow(String datasource) {
     leaseManager.borrow(new LeaseRequest(JobType.BATCH, datasource));

diff --git a/async-query/src/main/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManager.java b/async-query/src/main/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManager.java
@@ -92,7 +92,8 @@ public String description() {
 
     @Override
     public boolean test(LeaseRequest leaseRequest) {
-      if (leaseRequest.getJobType() != JobType.REFRESH && leaseRequest.getJobType() != JobType.STREAMING) {
+      if (leaseRequest.getJobType() != JobType.REFRESH
+          && leaseRequest.getJobType() != JobType.STREAMING) {
         return true;
       }
       return activeRefreshJobCount(stateStore, ALL_DATASOURCE).get() < refreshJobLimit();