[incubator-iotdb] branch fix_closed_channel_issue updated: fix file node processor

[caogaofei]

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

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


The following commit(s) were added to refs/heads/fix_closed_channel_issue by 
this push:
     new b8c1572  fix file node processor
b8c1572 is described below

commit b8c157236164bdf2e771e189459fcb629cbec9d6
Author: CGF <cgf1...@foxmail.com>
AuthorDate: Sun Mar 24 23:38:09 2019 +0800

    fix file node processor
---
 .../main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java
 
b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java
index 128db68..889f816 100644
--- 
a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java
+++ 
b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java
@@ -1415,6 +1415,7 @@ public class FileNodeProcessor extends Processor 
implements IStatistic {
       }
       for (File file : files) {
         if (!bufferFiles.contains(file.getPath())) {
+          System.out.println("TO delete file ~~~~  " + file.getPath());
           
FileReaderManager.getInstance().closeFileAndRemoveReader(file.getAbsolutePath());
           if (!file.delete()) {
             LOGGER.warn("Cannot delete BufferWrite file {}", file.getPath());