diff options
author | Andrei Rykov <arykov@ydb.tech> | 2023-12-21 17:03:12 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-12-21 17:03:12 +0100 |
commit | 5167ea1f13e570e7e44f0344cc6cc2ff6560913c (patch) | |
tree | bd2fd42daab350d63e101a07225b7c9632abeefc | |
parent | b3f47816434efbc64ed47bd8fd93edd9d8998ad2 (diff) | |
download | ydb-5167ea1f13e570e7e44f0344cc6cc2ff6560913c.tar.gz |
KIKIMR-20321 viewer tests asan fix (#525)
KIKIMR-20231/asan-fix
-rw-r--r-- | ydb/core/kqp/executer_actor/ut/kqp_executer_ut.cpp | 2 | ||||
-rw-r--r-- | ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp | 4 | ||||
-rw-r--r-- | ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp | 2 | ||||
-rw-r--r-- | ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp | 4 | ||||
-rw-r--r-- | ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp | 4 | ||||
-rw-r--r-- | ydb/core/sys_view/ut_common.cpp | 4 | ||||
-rw-r--r-- | ydb/core/sys_view/ut_kqp.cpp | 2 | ||||
-rw-r--r-- | ydb/core/testlib/test_client.cpp | 46 | ||||
-rw-r--r-- | ydb/core/testlib/test_client.h | 23 | ||||
-rw-r--r-- | ydb/core/viewer/viewer_ut.cpp | 4 | ||||
-rw-r--r-- | ydb/public/lib/deprecated/kicli/cpp_ut.cpp | 2 | ||||
-rw-r--r-- | ydb/services/keyvalue/grpc_service_ut.cpp | 2 | ||||
-rw-r--r-- | ydb/services/ydb/ydb_common_ut.h | 4 | ||||
-rw-r--r-- | ydb/services/ydb/ydb_table_ut.cpp | 2 |
14 files changed, 53 insertions, 52 deletions
diff --git a/ydb/core/kqp/executer_actor/ut/kqp_executer_ut.cpp b/ydb/core/kqp/executer_actor/ut/kqp_executer_ut.cpp index 989d2b3587e..062add1ddb2 100644 --- a/ydb/core/kqp/executer_actor/ut/kqp_executer_ut.cpp +++ b/ydb/core/kqp/executer_actor/ut/kqp_executer_ut.cpp @@ -43,7 +43,7 @@ TIntrusivePtr<IKqpGateway> MakeIcGateway(const TKikimrRunner& kikimr) { auto actorSystem = kikimr.GetTestServer().GetRuntime()->GetAnyNodeActorSystem(); return CreateKikimrIcGateway(TString(DefaultKikimrClusterName), "/Root", TKqpGatewaySettings(), actorSystem, kikimr.GetTestServer().GetRuntime()->GetNodeId(0), - TAlignedPagePoolCounters(), kikimr.GetTestServer().GetSettings().AppConfig.GetQueryServiceConfig()); + TAlignedPagePoolCounters(), kikimr.GetTestServer().GetSettings().AppConfig->GetQueryServiceConfig()); } [[maybe_unused]] diff --git a/ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp b/ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp index 30c06b8e730..1e4aadfd6a5 100644 --- a/ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp +++ b/ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp @@ -75,7 +75,7 @@ TIntrusivePtr<IKqpGateway> GetIcGateway(Tests::TServer& server) { std::shared_ptr<NYql::IKikimrGateway::IKqpTableMetadataLoader> loader = std::make_shared<TKqpTableMetadataLoader>(server.GetRuntime()->GetAnyNodeActorSystem(),TIntrusivePtr<NYql::TKikimrConfiguration>(nullptr), false); return CreateKikimrIcGateway(TestCluster, NKikimrKqp::QUERY_TYPE_SQL_GENERIC_QUERY, "/Root", std::move(loader), server.GetRuntime()->GetAnyNodeActorSystem(), - server.GetRuntime()->GetNodeId(0), counters, server.GetSettings().AppConfig.GetQueryServiceConfig()); + server.GetRuntime()->GetNodeId(0), counters, server.GetSettings().AppConfig->GetQueryServiceConfig()); } void TestListPathCommon(TIntrusivePtr<IKikimrGateway> gateway) { @@ -307,7 +307,7 @@ Y_UNIT_TEST_SUITE(KikimrIcGateway) { auto createSecretQueryResult = session.ExecuteSchemeQuery(createSecretQuery).GetValueSync(); UNIT_ASSERT_C(createSecretQueryResult.GetStatus() == NYdb::EStatus::SUCCESS, createSecretQueryResult.GetIssues().ToString()); } - + Y_UNIT_TEST(TestLoadServiceAccountSecretValueFromExternalDataSourceMetadata) { TKikimrRunner kikimr; kikimr.GetTestServer().GetRuntime()->GetAppData(0).FeatureFlags.SetEnableExternalDataSources(true); diff --git a/ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp b/ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp index 639f99ab4df..3e090a42c66 100644 --- a/ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp +++ b/ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp @@ -164,7 +164,7 @@ Y_UNIT_TEST_SUITE(KqpProxy) { ui16 mbusport = tp.GetPort(2134); auto settings = Tests::TServerSettings(mbusport).SetDomainName("Root").SetUseRealThreads(false); // set small compilation timeout to avoid long timer creation - settings.AppConfig.MutableTableServiceConfig()->SetCompileTimeoutMs(400); + settings.AppConfig->MutableTableServiceConfig()->SetCompileTimeoutMs(400); Tests::TServer::TPtr server = new Tests::TServer(settings); diff --git a/ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp b/ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp index 4607d23eeab..3bc943c7fd9 100644 --- a/ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp +++ b/ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp @@ -36,7 +36,7 @@ TIntrusivePtr<NKqp::IKqpGateway> GetIcGateway(Tests::TServer& server) { counters->TxProxyMon = new NTxProxy::TTxProxyMon(server.GetRuntime()->GetAppData(0).Counters); std::shared_ptr<NYql::IKikimrGateway::IKqpTableMetadataLoader> loader = std::make_shared<TKqpTableMetadataLoader>(server.GetRuntime()->GetAnyNodeActorSystem(),TIntrusivePtr<NYql::TKikimrConfiguration>(nullptr),false); return NKqp::CreateKikimrIcGateway(TestCluster, NKikimrKqp::QUERY_TYPE_SQL_GENERIC_QUERY, "/Root", std::move(loader), server.GetRuntime()->GetAnyNodeActorSystem(), - server.GetRuntime()->GetNodeId(0), counters, server.GetSettings().AppConfig.GetQueryServiceConfig()); + server.GetRuntime()->GetNodeId(0), counters, server.GetSettings().AppConfig->GetQueryServiceConfig()); } TIntrusivePtr<IKqpHost> CreateKikimrQueryProcessor(TIntrusivePtr<IKqpGateway> gateway, @@ -1162,7 +1162,7 @@ Y_UNIT_TEST_SUITE(KqpIndexes) { auto session = db.CreateSession().GetValueSync().GetSession(); const auto& config = kikimr.GetTestServer().GetSettings().AppConfig; - auto& tableSettings = config.GetTableServiceConfig(); + auto& tableSettings = config->GetTableServiceConfig(); bool useSchemeCacheMeta = tableSettings.GetUseSchemeCacheMetadata(); { diff --git a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp index 63695554175..536595ccf92 100644 --- a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp +++ b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp @@ -28,7 +28,7 @@ Y_UNIT_TEST_SUITE(KqpScheme) { auto db = kikimr.GetTableClient(); auto session = db.CreateSession().GetValueSync().GetSession(); - auto& tableSettings = kikimr.GetTestServer().GetSettings().AppConfig.GetTableServiceConfig(); + auto& tableSettings = kikimr.GetTestServer().GetSettings().AppConfig->GetTableServiceConfig(); bool useSchemeCacheMeta = tableSettings.GetUseSchemeCacheMetadata(); auto result = session.ExecuteDataQuery(R"( @@ -5831,7 +5831,7 @@ Y_UNIT_TEST_SUITE(KqpOlapScheme) { Y_UNIT_TEST(TenThousandColumns) { using namespace NArrow; - + TKikimrSettings runnerSettings; runnerSettings.WithSampleTables = false; TTestHelper testHelper(runnerSettings); diff --git a/ydb/core/sys_view/ut_common.cpp b/ydb/core/sys_view/ut_common.cpp index 069b42fcae3..89b86542ce3 100644 --- a/ydb/core/sys_view/ut_common.cpp +++ b/ydb/core/sys_view/ut_common.cpp @@ -51,8 +51,8 @@ TTestEnv::TTestEnv(ui32 staticNodes, ui32 dynamicNodes, ui32 storagePools, ui32 Settings->AddStoragePool(poolName, TString("/Root:") + poolName, 2); } - Settings->AppConfig.MutableTableServiceConfig()->SetEnableKqpDataQuerySourceRead(!disableSources); - Settings->AppConfig.MutableHiveConfig()->AddBalancerIgnoreTabletTypes(NKikimrTabletBase::TTabletTypes::SysViewProcessor); + Settings->AppConfig->MutableTableServiceConfig()->SetEnableKqpDataQuerySourceRead(!disableSources); + Settings->AppConfig->MutableHiveConfig()->AddBalancerIgnoreTabletTypes(NKikimrTabletBase::TTabletTypes::SysViewProcessor); Server = new Tests::TServer(*Settings); Server->EnableGRpc(grpcPort); diff --git a/ydb/core/sys_view/ut_kqp.cpp b/ydb/core/sys_view/ut_kqp.cpp index 55f9803bc5c..bd930aa7040 100644 --- a/ydb/core/sys_view/ut_kqp.cpp +++ b/ydb/core/sys_view/ut_kqp.cpp @@ -602,7 +602,7 @@ Y_UNIT_TEST_SUITE(SystemView) { TYsonFieldChecker check(ysonString, 29); - bool iterators = env.GetSettings()->AppConfig.GetTableServiceConfig().GetEnableKqpDataQuerySourceRead(); + bool iterators = env.GetSettings()->AppConfig->GetTableServiceConfig().GetEnableKqpDataQuerySourceRead(); check.Uint64GreaterOrEquals(0); // CPUTime check.Uint64GreaterOrEquals(0); // CompileCPUTime diff --git a/ydb/core/testlib/test_client.cpp b/ydb/core/testlib/test_client.cpp index 259d5cf6d9b..0f532cec0d3 100644 --- a/ydb/core/testlib/test_client.cpp +++ b/ydb/core/testlib/test_client.cpp @@ -239,14 +239,14 @@ namespace Tests { appData.PQConfig.MergeFrom(Settings->PQConfig); appData.PQClusterDiscoveryConfig.MergeFrom(Settings->PQClusterDiscoveryConfig); appData.NetClassifierConfig.MergeFrom(Settings->NetClassifierConfig); - appData.StreamingConfig.MergeFrom(Settings->AppConfig.GetGRpcConfig().GetStreamingConfig()); - appData.EnforceUserTokenRequirement = Settings->AppConfig.GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement(); - appData.DomainsConfig.MergeFrom(Settings->AppConfig.GetDomainsConfig()); - appData.ColumnShardConfig.MergeFrom(Settings->AppConfig.GetColumnShardConfig()); + appData.StreamingConfig.MergeFrom(Settings->AppConfig->GetGRpcConfig().GetStreamingConfig()); + appData.EnforceUserTokenRequirement = Settings->AppConfig->GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement(); + appData.DomainsConfig.MergeFrom(Settings->AppConfig->GetDomainsConfig()); + appData.ColumnShardConfig.MergeFrom(Settings->AppConfig->GetColumnShardConfig()); appData.PersQueueGetReadSessionsInfoWorkerFactory = Settings->PersQueueGetReadSessionsInfoWorkerFactory.get(); appData.DataStreamsAuthFactory = Settings->DataStreamsAuthFactory.get(); appData.PersQueueMirrorReaderFactory = Settings->PersQueueMirrorReaderFactory.get(); - appData.HiveConfig.MergeFrom(Settings->AppConfig.GetHiveConfig()); + appData.HiveConfig.MergeFrom(Settings->AppConfig->GetHiveConfig()); appData.DynamicNameserviceConfig = new TDynamicNameserviceConfig; auto dnConfig = appData.DynamicNameserviceConfig; @@ -315,11 +315,11 @@ namespace Tests { Cerr << "TServer::EnableGrpc on GrpcPort " << options.Port << ", node " << system->NodeId << Endl; - const size_t proxyCount = Max(ui32{1}, Settings->AppConfig.GetGRpcConfig().GetGRpcProxyCount()); + const size_t proxyCount = Max(ui32{1}, Settings->AppConfig->GetGRpcConfig().GetGRpcProxyCount()); TVector<TActorId> grpcRequestProxies; grpcRequestProxies.reserve(proxyCount); for (size_t i = 0; i < proxyCount; ++i) { - auto grpcRequestProxy = NGRpcService::CreateGRpcRequestProxy(Settings->AppConfig); + auto grpcRequestProxy = NGRpcService::CreateGRpcRequestProxy(*Settings->AppConfig); auto grpcRequestProxyId = system->Register(grpcRequestProxy, TMailboxType::ReadAsFilled); system->RegisterLocalService(NGRpcService::CreateGRpcRequestProxyId(), grpcRequestProxyId); grpcRequestProxies.push_back(grpcRequestProxyId); @@ -353,7 +353,7 @@ namespace Tests { } if (!options.SslData.Empty()) { - grpcService->SetDynamicNodeAuthParams(NKikimr::GetDynamicNodeAuthorizationParams(Settings->AppConfig.GetClientCertificateAuthorization())); + grpcService->SetDynamicNodeAuthParams(NKikimr::GetDynamicNodeAuthorizationParams(Settings->AppConfig->GetClientCertificateAuthorization())); } auto future = grpcService->Prepare( @@ -390,7 +390,7 @@ namespace Tests { GRpcServer->AddService(new NGRpcService::TGRpcCmsService(system, counters, grpcRequestProxies[0], true)); auto discoveryService = new NGRpcService::TGRpcDiscoveryService(system, counters, grpcRequestProxies[0], true); if (!options.SslData.Empty()) { - discoveryService->SetDynamicNodeAuthParams(NKikimr::GetDynamicNodeAuthorizationParams(Settings->AppConfig.GetClientCertificateAuthorization())); + discoveryService->SetDynamicNodeAuthParams(NKikimr::GetDynamicNodeAuthorizationParams(Settings->AppConfig->GetClientCertificateAuthorization())); } GRpcServer->AddService(discoveryService); GRpcServer->AddService(new NGRpcService::TGRpcYdbClickhouseInternalService(system, counters, appData.InFlightLimiterRegistry, grpcRequestProxies[0], true)); @@ -746,7 +746,7 @@ namespace Tests { Runtime->RegisterService(MakeTenantPoolRootID(), poolId, nodeIdx); if (Settings->EnableConfigsDispatcher) { // We overwrite icb settings here to save behavior when configs dispatcher are enabled - NKikimrConfig::TAppConfig initial = Settings->AppConfig; + NKikimrConfig::TAppConfig initial = *Settings->AppConfig; if (!initial.HasImmediateControlsConfig()) { initial.MutableImmediateControlsConfig()->CopyFrom(Settings->Controls); } @@ -839,7 +839,7 @@ namespace Tests { auto kqpProxySharedResources = std::make_shared<NKqp::TKqpProxySharedResources>(); IActor* kqpRmService = NKqp::CreateKqpResourceManagerActor( - Settings->AppConfig.GetTableServiceConfig().GetResourceManager(), nullptr, {}, kqpProxySharedResources); + Settings->AppConfig->GetTableServiceConfig().GetResourceManager(), nullptr, {}, kqpProxySharedResources); TActorId kqpRmServiceId = Runtime->Register(kqpRmService, nodeIdx); Runtime->RegisterService(NKqp::MakeKqpRmServiceID(Runtime->GetNodeId(nodeIdx)), kqpRmServiceId, nodeIdx); @@ -851,7 +851,7 @@ namespace Tests { std::shared_ptr<NKikimr::NKqp::IKqpFederatedQuerySetupFactory> federatedQuerySetupFactory = Settings->FederatedQuerySetupFactory; if (Settings->InitializeFederatedQuerySetupFactory) { - const auto& queryServiceConfig = Settings->AppConfig.GetQueryServiceConfig(); + const auto& queryServiceConfig = Settings->AppConfig->GetQueryServiceConfig(); auto httpProxyActorId = NFq::MakeYqlAnalyticsHttpProxyId(); Runtime->RegisterService( @@ -888,17 +888,17 @@ namespace Tests { ); } - IActor* kqpProxyService = NKqp::CreateKqpProxyService(Settings->AppConfig.GetLogConfig(), - Settings->AppConfig.GetTableServiceConfig(), - Settings->AppConfig.GetQueryServiceConfig(), - Settings->AppConfig.GetMetadataProviderConfig(), + IActor* kqpProxyService = NKqp::CreateKqpProxyService(Settings->AppConfig->GetLogConfig(), + Settings->AppConfig->GetTableServiceConfig(), + Settings->AppConfig->GetQueryServiceConfig(), + Settings->AppConfig->GetMetadataProviderConfig(), TVector<NKikimrKqp::TKqpSetting>(Settings->KqpSettings), nullptr, std::move(kqpProxySharedResources), federatedQuerySetupFactory); TActorId kqpProxyServiceId = Runtime->Register(kqpProxyService, nodeIdx); Runtime->RegisterService(NKqp::MakeKqpProxyID(Runtime->GetNodeId(nodeIdx)), kqpProxyServiceId, nodeIdx); - IActor* scriptFinalizeService = NKqp::CreateKqpFinalizeScriptService(Settings->AppConfig.GetQueryServiceConfig().GetFinalizeScriptServiceConfig(), Settings->AppConfig.GetMetadataProviderConfig(), federatedQuerySetupFactory); + IActor* scriptFinalizeService = NKqp::CreateKqpFinalizeScriptService(Settings->AppConfig->GetQueryServiceConfig().GetFinalizeScriptServiceConfig(), Settings->AppConfig->GetMetadataProviderConfig(), federatedQuerySetupFactory); TActorId scriptFinalizeServiceId = Runtime->Register(scriptFinalizeService, nodeIdx); Runtime->RegisterService(NKqp::MakeKqpFinalizeScriptServiceId(Runtime->GetNodeId(nodeIdx)), scriptFinalizeServiceId, nodeIdx); } @@ -1013,14 +1013,14 @@ namespace Tests { Runtime->RegisterService(MakePollerActorId(), actorId, nodeIdx); } - if (Settings->AppConfig.GetKafkaProxyConfig().GetEnableKafkaProxy()) { + if (Settings->AppConfig->GetKafkaProxyConfig().GetEnableKafkaProxy()) { NKafka::TListenerSettings settings; - settings.Port = Settings->AppConfig.GetKafkaProxyConfig().GetListeningPort(); - if (Settings->AppConfig.GetKafkaProxyConfig().HasSslCertificate()) { - settings.SslCertificatePem = Settings->AppConfig.GetKafkaProxyConfig().GetSslCertificate(); + settings.Port = Settings->AppConfig->GetKafkaProxyConfig().GetListeningPort(); + if (Settings->AppConfig->GetKafkaProxyConfig().HasSslCertificate()) { + settings.SslCertificatePem = Settings->AppConfig->GetKafkaProxyConfig().GetSslCertificate(); } - IActor* actor = NKafka::CreateKafkaListener(MakePollerActorId(), settings, Settings->AppConfig.GetKafkaProxyConfig()); + IActor* actor = NKafka::CreateKafkaListener(MakePollerActorId(), settings, Settings->AppConfig->GetKafkaProxyConfig()); TActorId actorId = Runtime->Register(actor, nodeIdx); Runtime->RegisterService(TActorId{}, actorId, nodeIdx); @@ -1061,7 +1061,7 @@ namespace Tests { { auto& controlPlaneStorageConfig = *protoConfig.MutableControlPlaneStorage(); controlPlaneStorageConfig.SetEnabled(true); - controlPlaneStorageConfig.SetUseInMemory(Settings->AppConfig.GetFederatedQueryConfig().GetControlPlaneStorage().GetUseInMemory()); + controlPlaneStorageConfig.SetUseInMemory(Settings->AppConfig->GetFederatedQueryConfig().GetControlPlaneStorage().GetUseInMemory()); auto& storage = *controlPlaneStorageConfig.MutableStorage(); storage.SetEndpoint(endpoint); storage.SetTablePrefix(prefix); diff --git a/ydb/core/testlib/test_client.h b/ydb/core/testlib/test_client.h index 445559d7f60..03b489c7d75 100644 --- a/ydb/core/testlib/test_client.h +++ b/ydb/core/testlib/test_client.h @@ -127,7 +127,7 @@ namespace Tests { TDuration KeepSnapshotTimeout = TDuration::Zero(); ui64 ChangesQueueItemsLimit = 0; ui64 ChangesQueueBytesLimit = 0; - NKikimrConfig::TAppConfig AppConfig; + std::shared_ptr<NKikimrConfig::TAppConfig> AppConfig; std::shared_ptr<TKikimrRunConfig> KikimrRunConfig; NKikimrConfig::TCompactionConfig CompactionConfig; TMap<ui32, TString> NodeKeys; @@ -167,8 +167,8 @@ namespace Tests { TServerSettings& SetEnableNodeBroker(bool value) { EnableNodeBroker = value; return *this; } TServerSettings& SetEnableConfigsDispatcher(bool value) { EnableConfigsDispatcher = value; return *this; } TServerSettings& SetUseRealThreads(bool value) { UseRealThreads = value; return *this; } - TServerSettings& SetAppConfig(const NKikimrConfig::TAppConfig value) { AppConfig = value; return *this; } - TServerSettings& InitKikimrRunConfig() { KikimrRunConfig = std::make_shared<TKikimrRunConfig>(AppConfig); return *this; } + TServerSettings& SetAppConfig(const NKikimrConfig::TAppConfig& value) { AppConfig = std::make_shared<NKikimrConfig::TAppConfig>(value); return *this; } + TServerSettings& InitKikimrRunConfig() { KikimrRunConfig = std::make_shared<TKikimrRunConfig>(*AppConfig); return *this; } TServerSettings& SetKeyFor(ui32 nodeId, TString keyValue) { NodeKeys[nodeId] = keyValue; return *this; } TServerSettings& SetEnableKqpSpilling(bool value) { EnableKqpSpilling = value; return *this; } TServerSettings& SetEnableForceFollowers(bool value) { EnableForceFollowers = value; return *this; } @@ -219,14 +219,15 @@ namespace Tests { , PQConfig(pqConfig) { AddStoragePool("test", "/" + DomainName + ":test"); - AppConfig.MutableTableServiceConfig()->MutableResourceManager()->MutableShardsScanningPolicy()->SetParallelScanningAvailable(true); - AppConfig.MutableTableServiceConfig()->MutableResourceManager()->MutableShardsScanningPolicy()->SetShardSplitFactor(16); - AppConfig.MutableHiveConfig()->SetWarmUpBootWaitingPeriod(10); - AppConfig.MutableHiveConfig()->SetMaxNodeUsageToKick(100); - AppConfig.MutableHiveConfig()->SetMinCounterScatterToBalance(100); - AppConfig.MutableHiveConfig()->SetMinScatterToBalance(100); - AppConfig.MutableHiveConfig()->SetObjectImbalanceToBalance(100); - AppConfig.MutableColumnShardConfig()->SetDisabledOnSchemeShard(false); + AppConfig = std::make_shared<NKikimrConfig::TAppConfig>(); + AppConfig->MutableTableServiceConfig()->MutableResourceManager()->MutableShardsScanningPolicy()->SetParallelScanningAvailable(true); + AppConfig->MutableTableServiceConfig()->MutableResourceManager()->MutableShardsScanningPolicy()->SetShardSplitFactor(16); + AppConfig->MutableHiveConfig()->SetWarmUpBootWaitingPeriod(10); + AppConfig->MutableHiveConfig()->SetMaxNodeUsageToKick(100); + AppConfig->MutableHiveConfig()->SetMinCounterScatterToBalance(100); + AppConfig->MutableHiveConfig()->SetMinScatterToBalance(100); + AppConfig->MutableHiveConfig()->SetObjectImbalanceToBalance(100); + AppConfig->MutableColumnShardConfig()->SetDisabledOnSchemeShard(false); FeatureFlags.SetEnableSeparationComputeActorsFromRead(true); } diff --git a/ydb/core/viewer/viewer_ut.cpp b/ydb/core/viewer/viewer_ut.cpp index e9a85510855..dd4d0459411 100644 --- a/ydb/core/viewer/viewer_ut.cpp +++ b/ydb/core/viewer/viewer_ut.cpp @@ -264,7 +264,7 @@ Y_UNIT_TEST_SUITE(Viewer) { void ChangeListNodes(TEvInterconnect::TEvNodesInfo::TPtr* ev, int nodesTotal) { auto& nodes = (*ev)->Get()->Nodes; - + auto sample = nodes[0]; nodes.clear(); @@ -444,7 +444,7 @@ Y_UNIT_TEST_SUITE(Viewer) { Ctest << "BASE_PERF = " << BASE_PERF << Endl; #ifndef SANITIZER_TYPE -#if !defined(NDEBUG) || defined(_hardening_enabled_) +#if !defined(NDEBUG) || defined(_hardening_enabled_) UNIT_ASSERT_VALUES_EQUAL_C(timer.Passed() < 30 * BASE_PERF, true, "timer = " << timer.Passed() << ", limit = " << 30 * BASE_PERF); #else UNIT_ASSERT_VALUES_EQUAL_C(timer.Passed() < 10 * BASE_PERF, true, "timer = " << timer.Passed() << ", limit = " << 10 * BASE_PERF); diff --git a/ydb/public/lib/deprecated/kicli/cpp_ut.cpp b/ydb/public/lib/deprecated/kicli/cpp_ut.cpp index 08238c3ddf9..4a678030641 100644 --- a/ydb/public/lib/deprecated/kicli/cpp_ut.cpp +++ b/ydb/public/lib/deprecated/kicli/cpp_ut.cpp @@ -39,7 +39,7 @@ Tests::TServer StartupKikimr(NGRpcProxy::TGRpcClientConfig& clientConfig, auto settings = Tests::TServerSettings(msgbusPort); settings.SetLogBackend(logBackend); - settings.AppConfig.CopyFrom(config); + settings.AppConfig->CopyFrom(config); settings.SetEnableSystemViews(false); Tests::TServer Server(settings); diff --git a/ydb/services/keyvalue/grpc_service_ut.cpp b/ydb/services/keyvalue/grpc_service_ut.cpp index 975e6ccc967..966956b7bdc 100644 --- a/ydb/services/keyvalue/grpc_service_ut.cpp +++ b/ydb/services/keyvalue/grpc_service_ut.cpp @@ -109,7 +109,7 @@ public: Server_->EnableGRpc(grpcOption); Tests::TClient annoyingClient(*ServerSettings); - if (ServerSettings->AppConfig.GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement()) { + if (ServerSettings->AppConfig->GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement()) { annoyingClient.SetSecurityToken("root@builtin"); } annoyingClient.InitRootScheme("Root"); diff --git a/ydb/services/ydb/ydb_common_ut.h b/ydb/services/ydb/ydb_common_ut.h index 706e513f0d1..b5f5dbc9b05 100644 --- a/ydb/services/ydb/ydb_common_ut.h +++ b/ydb/services/ydb/ydb_common_ut.h @@ -77,7 +77,7 @@ public: ServerSettings->AddStoragePoolType("hdd1"); ServerSettings->AddStoragePoolType("hdd2"); } - ServerSettings->AppConfig.MergeFrom(appConfig); + ServerSettings->AppConfig->MergeFrom(appConfig); ServerSettings->AuthConfig = appConfig.GetAuthConfig(); ServerSettings->FeatureFlags = appConfig.GetFeatureFlags(); ServerSettings->SetKqpSettings(kqpSettings); @@ -131,7 +131,7 @@ public: Server_->EnableGRpc(grpcOption); TClient annoyingClient(*ServerSettings); - if (ServerSettings->AppConfig.GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement()) { + if (ServerSettings->AppConfig->GetDomainsConfig().GetSecurityConfig().GetEnforceUserTokenRequirement()) { annoyingClient.SetSecurityToken("root@builtin"); } annoyingClient.InitRootScheme("Root"); diff --git a/ydb/services/ydb/ydb_table_ut.cpp b/ydb/services/ydb/ydb_table_ut.cpp index 6d5b2721450..2316c15a99f 100644 --- a/ydb/services/ydb/ydb_table_ut.cpp +++ b/ydb/services/ydb/ydb_table_ut.cpp @@ -587,7 +587,7 @@ Y_UNIT_TEST_SUITE(YdbYqlClient) { .UseSecureConnection(NYdbSslTestData::CaCrt) .SetEndpoint(location)); - auto& tableSettings = server.GetServer().GetSettings().AppConfig.GetTableServiceConfig(); + auto& tableSettings = server.GetServer().GetSettings().AppConfig->GetTableServiceConfig(); bool useSchemeCacheMeta = tableSettings.GetUseSchemeCacheMetadata(); { |