aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.com>2023-11-30 20:12:20 +0300
committerivanmorozov <ivanmorozov@yandex-team.com>2023-11-30 22:36:02 +0300
commit8e776e16ab601874538faa1d1fc675525f60f10a (patch)
treee618c352955fdcd9e0cc0060836f1767c0768b26
parentc2f81b1b5ffe34c9a9f5abc5405ddb538856cc43 (diff)
downloadydb-8e776e16ab601874538faa1d1fc675525f60f10a.tar.gz
use full user pool for scan
-rw-r--r--ydb/core/driver_lib/run/kikimr_services_initializers.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/driver_lib/run/kikimr_services_initializers.cpp b/ydb/core/driver_lib/run/kikimr_services_initializers.cpp
index 27448450c4..5334ad2403 100644
--- a/ydb/core/driver_lib/run/kikimr_services_initializers.cpp
+++ b/ydb/core/driver_lib/run/kikimr_services_initializers.cpp
@@ -2176,10 +2176,10 @@ TScanConveyorInitializer::TScanConveyorInitializer(const TKikimrRunConfig& runCo
void TScanConveyorInitializer::InitializeServices(NActors::TActorSystemSetup* setup, const NKikimr::TAppData* appData) {
NConveyor::TConfig serviceConfig;
if (Config.HasScanConveyorConfig()) {
+ AFL_NOTICE(NKikimrServices::TX_CONVEYOR)("event", "initialization")("config", Config.GetScanConveyorConfig().DebugString());
Y_ABORT_UNLESS(serviceConfig.DeserializeFromProto(Config.GetScanConveyorConfig()));
- }
- if (!serviceConfig.HasDefaultFractionOfThreadsCount()) {
- serviceConfig.SetDefaultFractionOfThreadsCount(0.33);
+ } else {
+ AFL_NOTICE(NKikimrServices::TX_CONVEYOR)("event", "initialization")("config", "no_section");
}
if (serviceConfig.IsEnabled()) {