Skip to content

Commit 9700cbb

Browse files
committed
test-fix
1 parent 0a3c2bc commit 9700cbb

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -152,15 +152,15 @@ protected Object reorderValueListAndBitMap(
152152

153153
private int getLastNonnullIndex(
154154
final int i, final BitMap originalBitMap, final BitMap deDuplicatedBitMap) {
155-
if (originalBitMap == null) {
156-
return index[deDuplicatedIndex[i]];
157-
}
158155
if (deDuplicatedIndex == null) {
159-
if (originalBitMap.isMarked(index[i])) {
156+
if (originalBitMap != null && originalBitMap.isMarked(index[i])) {
160157
deDuplicatedBitMap.mark(i);
161158
}
162159
return index[i];
163160
}
161+
if (originalBitMap == null) {
162+
return index[deDuplicatedIndex[i]];
163+
}
164164
int lastNonnullIndex = deDuplicatedIndex[i];
165165
int lastIndex = i > 0 ? deDuplicatedIndex[i - 1] : -1;
166166
while (originalBitMap.isMarked(index[lastNonnullIndex])) {

0 commit comments

Comments
 (0)