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 <[email protected]>
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;
     }

Reply via email to