You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/08/17 07:19:45 UTC
[iotdb] 01/02: change debug log to info to analyze the root cause of data lost
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 <xi...@gmail.com>
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(),