[iotdb] branch proceeding_vldb updated: fix v1

[ej...@apache.org]

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

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


The following commit(s) were added to refs/heads/proceeding_vldb by this push:
     new c33e86d  fix v1
c33e86d is described below

commit c33e86d705f50a05326e1d7fcaf0570f0a66c2bf
Author: EJTTianyu <16...@qq.com>
AuthorDate: Mon Feb 22 17:10:07 2021 +0800

    fix v1
---
 .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 5dceb6a..8a5401d 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -1213,6 +1213,13 @@ public class StorageGroupProcessor {
       updateEndTimeMap(tsFileProcessor);
       tsFileProcessor.asyncClose();
 
+      if (!config.isEnableSlidingMemTable()) {
+        workSequenceTsFileProcessors.remove(tsFileProcessor.getTimeRangeId());
+        // if unsequence files don't contain this time range id, we should remove it's version controller
+        if (!workUnsequenceTsFileProcessors.containsKey(tsFileProcessor.getTimeRangeId())) {
+          timePartitionIdVersionControllerMap.remove(tsFileProcessor.getTimeRangeId());
+        }
+      }
       logger.info("close a sequence tsfile processor {}", storageGroupName);
     } else {
       closingUnSequenceTsFileProcessor.add(tsFileProcessor);