[iotdb] branch encoding_parallel updated: temp commit

[hx...@apache.org]

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

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


The following commit(s) were added to refs/heads/encoding_parallel by this push:
     new 93bc197  temp commit
93bc197 is described below

commit 93bc1970bea622212af050c3b7a8d318b4516b30
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Tue Mar 16 01:09:08 2021 +0800

    temp commit
---
 .../iotdb/db/engine/flush/MultiThreadMemTableFlushTask.java    | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/MultiThreadMemTableFlushTask.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/MultiThreadMemTableFlushTask.java
index 93b66d3..fd3174b 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/flush/MultiThreadMemTableFlushTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/MultiThreadMemTableFlushTask.java
@@ -62,10 +62,12 @@ public class MultiThreadMemTableFlushTask implements IMemTableFlushTask {
       new LinkedBlockingQueue[threadSize]; // this initialization may be wasted.
 
   {
-    if (config.isEnableMemControl() && SystemInfo.getInstance().isEncodingFasterThanIo()) {
-      for (int i = 0; i < threadSize; i++) {
-        ioTaskQueues[i] = new LinkedBlockingQueue<>(config.getIoTaskQueueSizeForFlushing());
-      }
+    for (int i = 0; i < threadSize; i++) {
+      ioTaskQueues[i] =
+          config.isEnableMemControl() && SystemInfo.getInstance().isEncodingFasterThanIo()
+              ? new LinkedBlockingQueue<>(config.getIoTaskQueueSizeForFlushing())
+              : new LinkedBlockingQueue<>();
+      encodingTaskQueues[i] = new LinkedBlockingQueue<>();
     }
   }