Skip to content

Commit a23c2f6

Browse files
fix intervals counter for limit control (#16809)
1 parent 83c87d0 commit a23c2f6

File tree

1 file changed

+6
-6
lines changed
  • ydb/core/tx/columnshard/engines/reader/simple_reader/iterator

1 file changed

+6
-6
lines changed

ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/collections.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -48,16 +48,16 @@ ui32 TScanWithLimitCollection::GetInFlightIntervalsCount(const TCompareKeyForSca
4848
AFL_VERIFY(from < to);
4949
ui32 inFlightCountLocal = 0;
5050
{
51-
auto itUpperFinishedFrom = FinishedSources.upper_bound(from);
52-
auto itUpperFinishedTo = FinishedSources.upper_bound(to);
53-
for (auto&& it = itUpperFinishedFrom; it != itUpperFinishedTo; ++it) {
51+
auto itFinishedFrom = FinishedSources.lower_bound(from);
52+
auto itFinishedTo = FinishedSources.lower_bound(to);
53+
for (auto&& it = itFinishedFrom; it != itFinishedTo; ++it) {
5454
++inFlightCountLocal;
5555
}
5656
}
5757
{
58-
auto itUpperFetchingFrom = FetchingInFlightSources.upper_bound(from);
59-
auto itUpperFetchingTo = FetchingInFlightSources.upper_bound(to);
60-
for (auto&& it = itUpperFetchingFrom; it != itUpperFetchingTo; ++it) {
58+
auto itFetchingFrom = FetchingInFlightSources.lower_bound(from);
59+
auto itFetchingTo = FetchingInFlightSources.lower_bound(to);
60+
for (auto&& it = itFetchingFrom; it != itFetchingTo; ++it) {
6161
++inFlightCountLocal;
6262
}
6363
}

0 commit comments

Comments
 (0)