You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2019/06/27 01:52:21 UTC
[incubator-iotdb] branch feature_async_close_tsfile_stable_625
updated: add tsfile resource size and closing tsfile processor log
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch feature_async_close_tsfile_stable_625
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/feature_async_close_tsfile_stable_625 by this push:
new 2eb364f add tsfile resource size and closing tsfile processor log
2eb364f is described below
commit 2eb364f3c85a2e230c5de0d5cead88caa234d7b2
Author: qiaojialin <64...@qq.com>
AuthorDate: Thu Jun 27 09:52:02 2019 +0800
add tsfile resource size and closing tsfile processor log
---
.../org/apache/iotdb/db/engine/filenodeV2/FileNodeProcessorV2.java | 6 +++++-
.../apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java | 1 -
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/FileNodeProcessorV2.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/FileNodeProcessorV2.java
index 2b3b958..eeb0795 100755
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/FileNodeProcessorV2.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenodeV2/FileNodeProcessorV2.java
@@ -268,12 +268,14 @@ public class FileNodeProcessorV2 {
sequenceFileList.add(workSequenceTsFileProcessor.getTsFileResource());
}
unsealedTsFileProcessor = workSequenceTsFileProcessor;
+ LOGGER.info("FNP {} add a new resource, sequence file resource list size: {}", storageGroupName, sequenceFileList.size());
} else {
if (workUnSequenceTsFileProcessor == null) {
workUnSequenceTsFileProcessor = createTsFileProcessor(false);
unSequenceFileList.add(workUnSequenceTsFileProcessor.getTsFileResource());
}
unsealedTsFileProcessor = workUnSequenceTsFileProcessor;
+ LOGGER.info("FNP {} add a new resource, unsequence file resource list size: {}", storageGroupName, unSequenceFileList.size());
}
// insert BufferWrite
@@ -591,7 +593,9 @@ public class FileNodeProcessorV2 {
} else {
closingUnSequenceTsFileProcessor.remove(unsealedTsFileProcessor);
}
- LOGGER.info("signal closing file node condition");
+ LOGGER.info("storage group {} signal closing file node condition, closing tsfile processor size {}",
+ closingSequenceTsFileProcessor.size() + closingUnSequenceTsFileProcessor.size(), storageGroupName);
+
synchronized (closeFileNodeCondition) {
closeFileNodeCondition.notify();
}
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
index ed69cf6..4d3efb5 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
@@ -24,7 +24,6 @@ import static org.apache.iotdb.db.engine.filenodeV2.TsFileResourceV2.RESOURCE_SU
import java.io.File;
import java.io.IOException;
import org.apache.iotdb.db.engine.filenodeV2.TsFileResourceV2;
-import org.apache.iotdb.db.engine.filenodeV2.UnsealedTsFileProcessorV2;
import org.apache.iotdb.db.engine.memtable.IMemTable;
import org.apache.iotdb.db.engine.memtable.MemTableFlushTask;
import org.apache.iotdb.db.engine.memtable.PrimitiveMemTable;