From 33bdc1a8d0e3f0d03f3c4f2e4eebcd0fc0cbb032 Mon Sep 17 00:00:00 2001 From: ivanmorozov333 Date: Fri, 28 Mar 2025 10:54:17 +0300 Subject: in case request limit we have to limit simultaneous tasks by sources (#16363) --- .../tx/columnshard/engines/reader/simple_reader/iterator/scanner.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 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()); -- cgit v1.3