(iotdb) branch master updated: [Inconsistent copies] Add debug logs to the storage engine

[tanxinyu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5cbddff2732 [Inconsistent copies] Add debug logs to the storage engine
5cbddff2732 is described below

commit 5cbddff27327f826e834accfdec86a804fd825c5
Author: Xiangpeng Hu <65238551+hxpser...@users.noreply.github.com>
AuthorDate: Wed Aug 28 10:47:34 2024 +0800

    [Inconsistent copies] Add debug logs to the storage engine
---
 .../db/storageengine/dataregion/DataRegion.java    | 26 ++++++++++++++++++++++
 1 file changed, 26 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 836cb4e0aa8..99c6bcf5dc0 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -945,6 +945,7 @@ public class DataRegion implements IDataRegionForQuery {
     // init flush time map
     initFlushTimeMap(beforeTimePartition);
 
+    int insertCnt = 0;
     // if is sequence
     boolean isSequence = false;
     while (loc < insertTabletNode.getRowCount()) {
@@ -967,6 +968,15 @@ public class DataRegion implements IDataRegionForQuery {
                     beforeTimePartition,
                     noFailure)
                 && noFailure;
+        if (before < loc) {
+          insertCnt += 1;
+          logger.debug(
+              "insertTabletToTsFileProcessor, insertCnt:{}, noFailure:{}, 
before:{}, loc:{}",
+              insertCnt,
+              noFailure,
+              before,
+              loc);
+        }
         before = loc;
         beforeTimePartition = timePartitionId;
         isSequence = time > lastFlushTime;
@@ -986,6 +996,15 @@ public class DataRegion implements IDataRegionForQuery {
                       noFailure)
                   && noFailure;
           before = loc;
+          if (before < loc) {
+            insertCnt += 1;
+            logger.debug(
+                "insertTabletToTsFileProcessor, insertCnt:{}, noFailure:{}, 
before:{}, loc:{}",
+                insertCnt,
+                noFailure,
+                before,
+                loc);
+          }
           isSequence = true;
         }
       }
@@ -1005,6 +1024,13 @@ public class DataRegion implements IDataRegionForQuery {
                   beforeTimePartition,
                   noFailure)
               && noFailure;
+      insertCnt += 1;
+      logger.debug(
+          "insertTabletToTsFileProcessor, insertCnt:{}, noFailure:{}, 
before:{}, loc:{}",
+          insertCnt,
+          noFailure,
+          before,
+          loc);
     }
 
     return noFailure;