[incubator-iotdb] branch feature_async_close_tsfile updated: add fast return in RecoverPerformers

[ji...@apache.org]

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

jiangtian 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 be181a0  add fast return in RecoverPerformers
be181a0 is described below

commit be181a031e1180de7b0e5a41959e1c777641de7b
Author: 江天 <jt...@163.com>
AuthorDate: Thu Jun 20 13:56:05 2019 +0800

    add fast return in RecoverPerformers
---
 .../apache/iotdb/db/writelog/recover/SeqTsFileRecoverPerformer.java   | 4 ++++
 .../apache/iotdb/db/writelog/recover/UnseqTsFileRecoverPerformer.java | 3 +++
 2 files changed, 7 insertions(+)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverPerformer.java b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverPerformer.java
index da00942..1329c7e 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverPerformer.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverPerformer.java
@@ -74,6 +74,10 @@ public class SeqTsFileRecoverPerformer {
     }
 
     logReplayer.replayLogs();
+    if (recoverMemTable.isEmpty()) {
+      removeTruncatePosition(insertFile);
+      return;
+    }
 
     MemTableFlushTask tableFlushTask = new MemTableFlushTask(restorableTsFileIOWriter,
         logNodePrefix, 0, (a,b) -> {});
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverPerformer.java b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverPerformer.java
index 761a738..6861265 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverPerformer.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverPerformer.java
@@ -47,6 +47,9 @@ public class UnseqTsFileRecoverPerformer {
         resource.getModificationFile(), resource.getVersionController(), null,
         fileSchema, memTable);
     replayer.replayLogs();
+    if (memTable.isEmpty()) {
+      return;
+    }
     try {
       resource.flush(fileSchema, memTable, logNodePrefix, 0, (a,b) -> {});
       resource.appendMetadatas();