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