diff options
| -rw-r--r-- | ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp b/ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp index fd0bbde7b3e..b2613f97894 100644 --- a/ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp +++ b/ydb/core/tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp @@ -146,7 +146,7 @@ TConclusion<bool> TScanHead::BuildNextInterval() { } ui32 inFlightCountLocal = GetInFlightIntervalsCount(); AFL_VERIFY(IntervalsInFlightCount == inFlightCountLocal)("count_global", IntervalsInFlightCount)("count_local", inFlightCountLocal); - while (SortedSources.size() && inFlightCountLocal < InFlightLimit && Context->IsActive()) { + while (SortedSources.size() && inFlightCountLocal < InFlightLimit && FetchingInFlightSources.size() < InFlightLimit && Context->IsActive()) { FOR_DEBUG_LOG(NKikimrServices::COLUMNSHARD_SCAN_EVLOG, SortedSources.front()->AddEvent("f")); SortedSources.front()->StartProcessing(SortedSources.front()); FetchingSources.emplace_back(SortedSources.front()); |