This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch cluster_performance
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster_performance by this
push:
new e5cfe2a binding=1
e5cfe2a is described below
commit e5cfe2ab3c9ada4e96e9dad24982810952137ab4
Author: Ring-k <[email protected]>
AuthorDate: Tue Sep 8 15:59:27 2020 +0800
binding=1
---
cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
b/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
index 2499544..db338ec 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
@@ -88,7 +88,7 @@ public class LogDispatcher {
private BlockingQueue<SendLogRequest> createQueueAndBindingThread(Node node)
{
BlockingQueue<SendLogRequest> logBlockingQueue =
new ArrayBlockingQueue<>(4096);
- int bindingThreadNum = 2;
+ int bindingThreadNum = 1;
for (int i = 0; i < bindingThreadNum; i++) {
executorService.submit(new DispatcherThread(node, logBlockingQueue));
}