Skip to content

Commit 448ce42

Browse files
committed
sorter
1 parent 7da96db commit 448ce42

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 3 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+
}
155158
if (deDuplicatedIndex == null) {
156159
if (originalBitMap.isMarked(index[i])) {
157160
deDuplicatedBitMap.mark(i);
158161
}
159162
return index[i];
160163
}
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)