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 <[email protected]>
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);