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
commit e6ffaf768a6afc81c925ea31833420dcd8847142 Author: Jinrui.Zhang <[email protected]> AuthorDate: Sun Jun 19 23:49:39 2022 +0800 fix the bug that thread num wrong --- server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 ++-- .../iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java index 92a373a6d9..5f2987d461 100644 --- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java +++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java @@ -1552,12 +1552,12 @@ public class IoTDBDescriptor { Integer.parseInt( properties.getProperty( "coordinator_read_executor_size", - Integer.toString(conf.getTriggerForwardMQTTPoolSize())))); + Integer.toString(conf.getCoordinatorReadExecutorSize())))); conf.setCoordinatorWriteExecutorSize( Integer.parseInt( properties.getProperty( "coordinator_write_executor_size", - Integer.toString(conf.getTriggerForwardMQTTPoolSize())))); + Integer.toString(conf.getCoordinatorWriteExecutorSize())))); } private void loadCQProps(Properties properties) { diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java index 35c301e230..52f455b1f0 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java @@ -90,7 +90,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { if (type == QueryType.READ) { return dispatchRead(instances); } else { - return dispatchWriteSync(instances); + return dispatchWrite(instances); } }
