Skip to content

Commit

Permalink
fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
ivanmorozov333 committed Feb 2, 2025
1 parent c4bb812 commit ac60677
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
3 changes: 2 additions & 1 deletion ydb/core/formats/arrow/accessor/sub_columns/iterators.h
Original file line number Diff line number Diff line change
Expand Up @@ -230,6 +230,7 @@ class TReadIteratorOrderedKeys {
return;
} else if (SortedIterators.front()->GetRecordIndex() < recordIndex) {
std::pop_heap(SortedIterators.begin(), SortedIterators.end(), TIteratorsComparator());
auto& itColumn = *SortedIterators.back();
if (!itColumn.Next()) {
SortedIterators.pop_back();
} else {
Expand All @@ -238,7 +239,7 @@ class TReadIteratorOrderedKeys {
continue;
}
startRecordActor(recordIndex);
while (SortedIterators.size() && SortedIterators.front()->GetRecordIndex() == i) {
while (SortedIterators.size() && SortedIterators.front()->GetRecordIndex() == recordIndex) {
std::pop_heap(SortedIterators.begin(), SortedIterators.end(), TIteratorsComparator());
auto& itColumn = *SortedIterators.back();
kvActor(itColumn.GetKeyIndex(), itColumn.GetValue(), itColumn.IsColumnKey());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -293,7 +293,7 @@ class TSubColumnsMerger: public IColumnMerger {
const auto finishRecord = [&]() {
builder.FinishRecord();
};
OrderedIterators[sourceIdx].ReadRecords(recordIdx, startRecord, addKV, finishRecord);
OrderedIterators[sourceIdx].ReadRecord(recordIdx, startRecord, addKV, finishRecord);
}
return builder.Finish(Context);
}
Expand Down

0 comments on commit ac60677

Please sign in to comment.