This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch ml_0815_data_lost in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3afd7be8dca4dc821f4cb076ac2baa1a54db1621 Author: Jinrui.Zhang <[email protected]> AuthorDate: Mon Aug 15 12:25:37 2022 +0800 change debug log to info to analyze the root cause of data lost --- .../apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 2 +- .../apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java index 7ee776acda..26d4b0987a 100644 --- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java +++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java @@ -235,7 +235,7 @@ public class LogDispatcher { List<TLogBatch> logBatches = new ArrayList<>(); long startIndex = syncStatus.getNextSendingIndex(); long maxIndexWhenBufferedRequestEmpty = startIndex; - logger.debug("[GetBatch] startIndex: {}", startIndex); + logger.info("[GetBatch] startIndex: {}", startIndex); long endIndex; if (bufferedRequest.size() <= config.getReplication().getMaxRequestPerBatch()) { // Use drainTo instead of poll to reduce lock overhead diff --git a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java index fa7a4aa502..59c17e4609 100644 --- a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java +++ b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java @@ -180,7 +180,7 @@ public class DataRegionStateMachine extends BaseStateMachine { Thread.currentThread().interrupt(); } } - logger.debug( + logger.info( "region = {}, queue size {}, startSyncIndex = {}, endSyncIndex = {}", region.getDataRegionId(), requestCache.size(),
