This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch cluster_oom in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit babdea12756a59b7ddbf4b155c40ce94ef0a9927 Author: LebronAl <[email protected]> AuthorDate: Wed Oct 27 11:06:40 2021 +0800 add log --- .../java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java b/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java index 3ae298c..96c11d7 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java @@ -616,6 +616,11 @@ public abstract class RaftLogManager { } if (needToCompactLog) { + logger.error( + "Trigger compact:numToReserveForNew:{},sizeToReserveForNew:{},sizeToReserveForConfig:{}", + numToReserveForNew, + sizeToReserveForNew, + minNumOfLogsInMem); int numForNew = Math.min(numToReserveForNew, sizeToReserveForNew); int sizeToReserveForConfig = minNumOfLogsInMem; startTime = Statistic.RAFT_SENDER_COMMIT_DELETE_EXCEEDING_LOGS.getOperationStartTime(); @@ -869,7 +874,7 @@ public abstract class RaftLogManager { long compactIndex = Math.min(committedEntryManager.getDummyIndex() + removeSize, maxHaveAppliedCommitIndex - 1); try { - logger.debug( + logger.info( "{}: Before compaction index {}-{}, compactIndex {}, removeSize {}, committedLogSize " + "{}, maxAppliedLog {}", name, @@ -883,7 +888,7 @@ public abstract class RaftLogManager { if (ClusterDescriptor.getInstance().getConfig().isEnableRaftLogPersistence()) { getStableEntryManager().removeCompactedEntries(compactIndex); } - logger.debug( + logger.info( "{}: After compaction index {}-{}, committedLogSize {}", name, getFirstIndex(),
