This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a commit to branch test_wal_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/test_wal_sync by this push:
     new a38ae2bd21 log
a38ae2bd21 is described below

commit a38ae2bd21d5eb58832f3ef81f8f7b6ea10df146
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Tue Jun 28 13:17:03 2022 +0800

    log
---
 .../org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java | 4 ++++
 server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java        | 1 +
 2 files changed, 5 insertions(+)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
index 272c244a1e..7682f118a8 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
@@ -104,6 +104,10 @@ public class MultiLeaderServerImpl {
     synchronized (stateMachine) {
       IndexedConsensusRequest indexedConsensusRequest =
           buildIndexedConsensusRequestForLocalRequest(request);
+      logger.info(
+          "index after build: safeIndex: {}, searchIndex: {}",
+          indexedConsensusRequest.getSafelyDeletedSearchIndex(),
+          indexedConsensusRequest.getSearchIndex());
       TSStatus result = stateMachine.write(indexedConsensusRequest);
       logDispatcher.offer(indexedConsensusRequest);
       return result;
diff --git a/server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java 
b/server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java
index 9c017f3a0f..4c70507cce 100644
--- a/server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java
@@ -667,6 +667,7 @@ public class WALNode implements IWALNode {
       if (needUpdatingFilesToSearch || filesToSearch == null) {
         updateFilesToSearch();
         if (needUpdatingFilesToSearch) {
+          logger.info("update file to search failed");
           return false;
         }
       }

Reply via email to