Skip to content

Commit f3a692c

Browse files
committed
fix
1 parent a0ca8fb commit f3a692c

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -455,8 +455,7 @@ protected BitMap[] initBitmapsForSplit(int columnSize, int rowSize) {
455455
final BitMap[] splitBitMaps = new BitMap[columnSize];
456456
boolean hasBitMap = false;
457457
for (int i = 0; i < columnSize && i < this.bitMaps.length; ++i) {
458-
if (this.bitMaps[i] != null
459-
&& !BitMapUtils.isAllUnmarked(this.bitMaps[i], sourceRowCount)) {
458+
if (this.bitMaps[i] != null && !BitMapUtils.isAllUnmarked(this.bitMaps[i], sourceRowCount)) {
460459
splitBitMaps[i] = new BitMap(rowSize);
461460
hasBitMap = true;
462461
}

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,6 @@ public static boolean isAllUnmarked(final BitMap bitMap, final int rowCount) {
5959
}
6060

6161
final int remainingBitCount = checkedSize % Byte.SIZE;
62-
return remainingBitCount == 0
63-
|| (bytes[fullByteCount] & ((1 << remainingBitCount) - 1)) == 0;
62+
return remainingBitCount == 0 || (bytes[fullByteCount] & ((1 << remainingBitCount) - 1)) == 0;
6463
}
6564
}

0 commit comments

Comments
 (0)