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);
}