[incubator-iotdb] branch feature_async_close_tsfile updated: fix flush

[li...@apache.org]

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

liurui pushed a commit to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
     new 4376b25  fix flush
4376b25 is described below

commit 4376b253cf8ef349aaa16527b07a38274e20384c
Author: liuruiyiyang <24...@qq.com>
AuthorDate: Wed Jun 12 16:45:16 2019 +0800

    fix flush
---
 .../org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java   | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
index ca90b76..6557efc 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
@@ -365,9 +365,6 @@ public class BufferWriteProcessor extends Processor {
 
   // keyword synchronized is added in this method, so that only one flush task can be submitted now.
   private Future<Boolean> flush(boolean isCloseTaskCalled) throws IOException {
-    if (!isCloseTaskCalled) {
-      throw new IOException("BufferWriteProcessor closed");
-    }
     // statistic information for flush
     if (lastFlushTime > 0) {
       if (LOGGER.isInfoEnabled()) {