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
commit 797d25a79fa928b5534bbf821ff09e204f7a5124 Author: Caideyipi <[email protected]> AuthorDate: Fri Mar 27 16:08:38 2026 +0800 grass --- .../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 7 ++++++- .../common/tsfile/parser/scan/TsFileInsertionEventScanParser.java | 6 ++++-- 2 files changed, 10 insertions(+), 3 deletions(-) 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 d7d9c3a5a25..d7794b12c7b 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,12 @@ public class IoTDBPipeDataSinkIT extends AbstractPipeDualTreeModelAutoIT { "count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*", "count(timeseries),", Collections.singleton("4,"), - 10); + 15); + TestUtils.assertDataAlwaysOnEnv( + receiverEnv, + "count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*", + "count(timeseries),", + Collections.singleton("4,")); } 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 d35d622e6b5..9f7f451fb4c 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 @@ -32,6 +32,7 @@ import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern; import org.apache.iotdb.db.auth.AuthorityChecker; import org.apache.iotdb.db.pipe.event.common.PipeInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent; +import org.apache.iotdb.db.pipe.event.common.tsfile.PipeTsFileInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tsfile.parser.TsFileInsertionEventParser; import org.apache.iotdb.db.pipe.event.common.tsfile.parser.util.ModsOperationUtil; import org.apache.iotdb.db.pipe.resource.PipeDataNodeResourceManager; @@ -685,8 +686,9 @@ public class TsFileInsertionEventScanParser extends TsFileInsertionEventParser { return true; } else if (chunkHeader.getMeasurementID().equals("s1")) { LOGGER.warn( - "s1 not filtered, currentModifications: {}", - currentModifications.getDeviceOverlapped(new PartialPath("root.**"))); + "s1 not filtered, currentModifications: {}, modFile: {}", + currentModifications.getDeviceOverlapped(new PartialPath("root.**")), + ((PipeTsFileInsertionEvent) sourceEvent).getModFile()); } }
