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

xingtanzjr pushed a commit to branch xingtanzjr/write_opt
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/xingtanzjr/write_opt by this 
push:
     new f57aee6577 spotless
f57aee6577 is described below

commit f57aee65774d6c39dda69f18deb2beed626742ac
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Sun Jun 19 23:17:05 2022 +0800

    spotless
---
 server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
index 528234f7fc..111a9222a6 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
@@ -145,13 +145,15 @@ public class Coordinator {
 
   // TODO: (xingtanzjr) need to redo once we have a concrete policy for the 
threadPool management
   private ExecutorService getQueryExecutor() {
-    int coordinatorReadExecutorSize = 
IoTDBDescriptor.getInstance().getConfig().getCoordinatorReadExecutorSize();
+    int coordinatorReadExecutorSize =
+        
IoTDBDescriptor.getInstance().getConfig().getCoordinatorReadExecutorSize();
     return IoTDBThreadPoolFactory.newFixedThreadPool(
         coordinatorReadExecutorSize, COORDINATOR_EXECUTOR_NAME);
   }
 
   private ExecutorService getWriteExecutor() {
-    int coordinatorWriteExecutorSize = 
IoTDBDescriptor.getInstance().getConfig().getCoordinatorWriteExecutorSize();
+    int coordinatorWriteExecutorSize =
+        
IoTDBDescriptor.getInstance().getConfig().getCoordinatorWriteExecutorSize();
     return IoTDBThreadPoolFactory.newFixedThreadPool(
         coordinatorWriteExecutorSize, COORDINATOR_WRITE_EXECUTOR_NAME);
   }

Reply via email to