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

justinchen pushed a commit to branch run-ci-mod
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/run-ci-mod by this push:
     new cfb659d3573 log
cfb659d3573 is described below

commit cfb659d3573b08eb26a98392cb840dd27538ded0
Author: Caideyipi <[email protected]>
AuthorDate: Fri Mar 27 15:43:19 2026 +0800

    log
---
 .../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java      | 2 +-
 .../common/tsfile/parser/scan/TsFileInsertionEventScanParser.java   | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
index 07d31df2050..d7d9c3a5a25 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
@@ -621,7 +621,7 @@ public class IoTDBPipeDataSinkIT extends 
AbstractPipeDualTreeModelAutoIT {
           "count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*",
           "count(timeseries),",
           Collections.singleton("4,"),
-          30);
+          10);
     } finally {
       TestUtils.executeNonQueries(
           senderEnv,
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
index 2bd22c8b0bc..884032a989c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
@@ -65,6 +65,8 @@ import org.apache.tsfile.write.UnSupportedDataTypeException;
 import org.apache.tsfile.write.record.Tablet;
 import org.apache.tsfile.write.schema.IMeasurementSchema;
 import org.apache.tsfile.write.schema.MeasurementSchema;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.io.IOException;
@@ -79,6 +81,8 @@ import java.util.Objects;
 
 public class TsFileInsertionEventScanParser extends TsFileInsertionEventParser 
{
 
+  private static final Logger LOGGER =
+      LoggerFactory.getLogger(TsFileInsertionEventScanParser.class);
   private final long startTime;
   private final long endTime;
   private final Filter filter;
@@ -678,6 +682,8 @@ public class TsFileInsertionEventScanParser extends 
TsFileInsertionEventParser {
               currentModifications)) {
         tsFileSequenceReader.position(nextMarkerOffset);
         return true;
+      } else if (chunkHeader.getMeasurementID().equals("s1")) {
+        LOGGER.warn("s1 not filtered, currentModifications: {}", 
currentModifications);
       }
     }
 

Reply via email to