This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch sync_from_iotdb_master_20260528 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f5f469366fa658075a65b66444de315c3df05f7a Author: Caideyipi <[email protected]> AuthorDate: Thu May 28 15:52:50 2026 +0800 Pipe: Fixed the test for #17770 (#17779) --- .../pipe/event/TsFileInsertionEventParserTest.java | 43 +++++++++++++++++----- 1 file changed, 33 insertions(+), 10 deletions(-) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java index 4cf5ac24e19..c70387ee175 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java @@ -343,11 +343,26 @@ public class TsFileInsertionEventParserTest { false)) { final Iterator<TabletInsertionEvent> iterator = parser.toTabletInsertionEvents().iterator(); Assert.assertTrue(iterator.hasNext()); - final Tablet parsedTablet = - ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); - assertBitMapExistence(parsedTablet, false, false, true); - Assert.assertTrue(parsedTablet.isNull(1, 2)); - Assert.assertFalse(iterator.hasNext()); + Tablet parsedTablet = ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); + if (parsedTablet.getSchemas().size() == 3) { + assertBitMapExistence(parsedTablet, false, false, true); + Assert.assertTrue(parsedTablet.isNull(1, 2)); + Assert.assertFalse(iterator.hasNext()); + } else { + if (parsedTablet.getSchemas().get(1).getMeasurementName().equals("dense")) { + Assert.assertNull(parsedTablet.getBitMaps()); + } else { + Assert.assertTrue(parsedTablet.isNull(1, 1)); + } + while (iterator.hasNext()) { + parsedTablet = ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); + if (parsedTablet.getSchemas().get(1).getMeasurementName().equals("dense")) { + Assert.assertNull(parsedTablet.getBitMaps()); + } else { + Assert.assertTrue(parsedTablet.isNull(1, 1)); + } + } + } } } finally { CommonDescriptor.getInstance() @@ -1101,11 +1116,19 @@ public class TsFileInsertionEventParserTest { false)) { final Iterator<TabletInsertionEvent> iterator = parser.toTabletInsertionEvents().iterator(); Assert.assertTrue(iterator.hasNext()); - final Tablet parsedTablet = - ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); - assertBitMapExistence(parsedTablet, false, true); - Assert.assertTrue(parsedTablet.isNull(1, 1)); - Assert.assertFalse(iterator.hasNext()); + Tablet parsedTablet = ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); + if (parsedTablet.getSchemas().size() > 1) { + assertBitMapExistence(parsedTablet, false, true); + Assert.assertTrue(parsedTablet.isNull(1, 1)); + Assert.assertFalse(iterator.hasNext()); + } else { + Assert.assertNull(parsedTablet.getBitMaps()); + Assert.assertTrue(iterator.hasNext()); + while (iterator.hasNext()) { + parsedTablet = ((PipeRawTabletInsertionEvent) iterator.next()).convertToTablet(); + Assert.assertNull(parsedTablet.getBitMaps()); + } + } } } finally { CommonDescriptor.getInstance()
