This is an automated email from the ASF dual-hosted git repository.
Caideyipi 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 623532a23a1 Pipe: Fixed the test for #17770 (#17779)
623532a23a1 is described below
commit 623532a23a1cdbe523dcc2c150e07db8f27b3b91
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 3ce07680ce6..825a5bf6e66 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
@@ -340,11 +340,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()
@@ -1095,11 +1110,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()
