[iotdb] 03/03: spotless apply

[hui]

This is an automated email from the ASF dual-hosted git repository.

hui pushed a commit to branch lmh/groupByTest
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 930d22460797549e5db3ada4b44a5039e2247165
Author: Minghui Liu <liuminghui...@foxmail.com>
AuthorDate: Fri Apr 14 10:11:54 2023 +0800

    spotless apply
---
 .../mpp/execution/exchange/SharedTsBlockQueue.java  | 21 ++++++++++-----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
index 9965262ef1..bf1aa4e660 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
@@ -42,7 +42,6 @@ import java.util.Queue;
 
 import static com.google.common.util.concurrent.Futures.immediateVoidFuture;
 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
-import static 
org.apache.iotdb.db.mpp.statistics.QueryStatistics.RESERVE_MEMORY;
 import static org.apache.iotdb.db.mpp.statistics.QueryStatistics.FREE_MEM;
 import static org.apache.iotdb.db.mpp.statistics.QueryStatistics.NOTIFY_END;
 import static 
org.apache.iotdb.db.mpp.statistics.QueryStatistics.NOTIFY_NEW_TSBLOCK;
@@ -229,16 +228,16 @@ public class SharedTsBlockQueue {
     Pair<ListenableFuture<Void>, Boolean> pair;
     try {
       pair =
-        localMemoryManager
-            .getQueryPool()
-            .reserve(
-                localFragmentInstanceId.getQueryId(),
-                fullFragmentInstanceId,
-                localPlanNodeId,
-                tsBlock.getRetainedSizeInBytes(),
-                maxBytesCanReserve);
-    blockedOnMemory = pair.left;
-    bufferRetainedSizeInBytes += tsBlock.getRetainedSizeInBytes();
+          localMemoryManager
+              .getQueryPool()
+              .reserve(
+                  localFragmentInstanceId.getQueryId(),
+                  fullFragmentInstanceId,
+                  localPlanNodeId,
+                  tsBlock.getRetainedSizeInBytes(),
+                  maxBytesCanReserve);
+      blockedOnMemory = pair.left;
+      bufferRetainedSizeInBytes += tsBlock.getRetainedSizeInBytes();
     } finally {
       QUERY_STATISTICS.addCost(RESERVE_MEMORY, System.nanoTime() - startTime);
     }