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 2021/06/29 05:02:27 UTC
[iotdb] branch rel/0.11 updated: add rmeove compaction log
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.11 by this push:
new c0e266a add rmeove compaction log
c0e266a is described below
commit c0e266a5ed81eac852037ff913166b003ea97283
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Jun 29 13:02:01 2021 +0800
add rmeove compaction log
---
.../compaction/level/LevelCompactionTsFileManagement.java | 12 +++++++-----
.../iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 1 -
2 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
index 208941d..427a14c 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
@@ -708,11 +708,13 @@ public class LevelCompactionTsFileManagement extends TsFileManagement {
} finally {
isSeqMerging = false;
// reset the merge working state to false
- logger.info(
- "{} [Compaction] merge end time isSeq = {}, consumption: {} ms",
- storageGroupName,
- sequence,
- System.currentTimeMillis() - startTimeMillis);
+ if (isMergeExecutedInCurrentTask) {
+ logger.info(
+ "{} [Compaction] merge end time isSeq = {}, consumption: {} ms",
+ storageGroupName,
+ sequence,
+ System.currentTimeMillis() - startTimeMillis);
+ }
}
return isMergeExecutedInCurrentTask;
}
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 6b70bf5..f2b2e20 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
@@ -1878,7 +1878,6 @@ public class StorageGroupProcessor {
}
private void syncCompactOnePartition(long timePartition, boolean fullMerge) {
- logger.info("{} submit a compaction merge task", storageGroupName);
try {
// fork and filter current tsfile, then commit then to compaction merge
tsFileManagement.forkCurrentFileList(timePartition);