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;
}
}