[incubator-iotdb] branch feature_async_close_tsfile updated: fix delete storage group

[qi...@apache.org]

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

qiaojialin 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 d7f9546  fix delete storage group
     new 1ce88c0  Merge remote-tracking branch 'origin/feature_async_close_tsfile' into feature_async_close_tsfile
d7f9546 is described below

commit d7f9546df68f8bbddf52fc83776f93f176b04331
Author: qiaojialin <64...@qq.com>
AuthorDate: Fri Jun 28 23:09:07 2019 +0800

    fix delete storage group
---
 .../java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java b/iotdb/src/main/java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java
index b0cb134..e760f42 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java
@@ -503,10 +503,9 @@ public class OverflowQPExecutor extends QueryProcessExecutor {
                 }
               }
             }
-            fileNodeManager.syncCloseAllProcessor();
             for (String deleteFileNode : deleteFielNodes) {
               // close processor
-//              fileNodeManager.deleteOneFileNode(deleteFileNode);
+              fileNodeManager.deleteOneFileNode(deleteFileNode);
             }
           }
           break;
@@ -516,7 +515,7 @@ public class OverflowQPExecutor extends QueryProcessExecutor {
         default:
           throw new ProcessorException("unknown namespace type:" + namespaceType);
       }
-    } catch (PathErrorException | IOException e) {
+    } catch (PathErrorException | IOException | FileNodeManagerException e) {
       throw new ProcessorException(e);
     }
     return true;