You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by he...@apache.org on 2023/04/26 05:29:00 UTC
[iotdb] branch fast_write_test_with_guoneng updated: add more log
This is an automated email from the ASF dual-hosted git repository.
heiming pushed a commit to branch fast_write_test_with_guoneng
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fast_write_test_with_guoneng by this push:
new c92ff2b6b1 add more log
c92ff2b6b1 is described below
commit c92ff2b6b1f08f5b72d0b881d45f2e57a2409762
Author: HeimingZ <zh...@qq.com>
AuthorDate: Wed Apr 26 13:27:51 2023 +0800
add more log
---
.../src/main/java/org/apache/iotdb/db/wal/node/WALNode.java | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
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 283c4fdd2c..be7fa746c6 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
@@ -668,6 +668,7 @@ public class WALNode implements IWALNode {
}
IndexedConsensusRequest request = itr.next();
+ logger.info("Read PlanNode-{} from wal node-{}.", request.getSearchIndex(), identifier);
nextSearchIndex = request.getSearchIndex() + 1;
return request;
}
@@ -700,13 +701,11 @@ public class WALNode implements IWALNode {
@Override
public void skipTo(long targetIndex) {
- if (targetIndex < nextSearchIndex) {
- logger.warn(
- "Skip from {} to {}, it's a dangerous operation because insert plan {} may have been lost.",
- nextSearchIndex,
- targetIndex,
- targetIndex);
- }
+ logger.info(
+ "Skip from {} to {}, it's a dangerous operation because insert plan {} may have been lost.",
+ nextSearchIndex,
+ targetIndex,
+ targetIndex);
reset();
nextSearchIndex = targetIndex;
}