Fix

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java

@@ -27,6 +27,7 @@
 import org.apache.iotdb.db.pipe.resource.memory.InsertNodeMemoryEstimator;
 import org.apache.iotdb.db.queryengine.plan.analyze.cache.schema.DataNodeDevicePathCache;
 import org.apache.iotdb.db.queryengine.plan.statement.crud.InsertTabletStatement;
+import org.apache.iotdb.db.utils.BitMapUtils;
 
 import org.apache.tsfile.enums.ColumnCategory;
 import org.apache.tsfile.enums.TSDataType;
@@ -347,7 +348,7 @@ private static Pair<BitMap[], Long> readBitMapsFromBufferWithMemory(
         final Binary valueBinary = ReadWriteIOUtils.readBinary(byteBuffer);
         final byte[] byteArray = valueBinary.getValues();
         final BitMap bitMap = new BitMap(size, byteArray);
-        if (bitMap.isAllUnmarked(Math.min(rowSize, bitMap.getSize()))) {
+        if (BitMapUtils.isAllUnmarked(bitMap, rowSize)) {
           continue;
         }
         bitMaps[i] = bitMap;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertTabletNode.java

@@ -456,7 +456,7 @@ protected BitMap[] initBitmapsForSplit(int columnSize, int rowSize) {
     boolean hasBitMap = false;
     for (int i = 0; i < columnSize && i < this.bitMaps.length; ++i) {
       if (this.bitMaps[i] != null
-          && !this.bitMaps[i].isAllUnmarked(Math.min(sourceRowCount, this.bitMaps[i].getSize()))) {
+          && !BitMapUtils.isAllUnmarked(this.bitMaps[i], sourceRowCount)) {
         splitBitMaps[i] = new BitMap(rowSize);
         hasBitMap = true;
       }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/BitMapUtils.java

@@ -44,7 +44,7 @@ public static BitMap[] compactBitMaps(final BitMap[] bitMaps, final int rowCount
     return hasMarkedBitMap ? bitMaps : null;
   }
 
-  private static boolean isAllUnmarked(final BitMap bitMap, final int rowCount) {
+  public static boolean isAllUnmarked(final BitMap bitMap, final int rowCount) {
     final int checkedSize = Math.min(rowCount, bitMap.getSize());
     if (checkedSize <= 0) {
       return true;
@@ -60,6 +60,6 @@ private static boolean isAllUnmarked(final BitMap bitMap, final int rowCount) {
 
     final int remainingBitCount = checkedSize % Byte.SIZE;
     return remainingBitCount == 0
-        || (bytes[fullByteCount] & (0xFF << (Byte.SIZE - remainingBitCount))) == 0;
+        || (bytes[fullByteCount] & ((1 << remainingBitCount) - 1)) == 0;
   }
 }