aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAndrei Rykov <arykov@ydb.tech>2023-12-21 17:03:12 +0100
committerGitHub <noreply@github.com>2023-12-21 17:03:12 +0100
commit5167ea1f13e570e7e44f0344cc6cc2ff6560913c (patch)
treebd2fd42daab350d63e101a07225b7c9632abeefc
parentb3f47816434efbc64ed47bd8fd93edd9d8998ad2 (diff)
downloadydb-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.cpp2
-rw-r--r--ydb/core/kqp/provider/yql_kikimr_gateway_ut.cpp4
-rw-r--r--ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp2
-rw-r--r--ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp4
-rw-r--r--ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp4
-rw-r--r--ydb/core/sys_view/ut_common.cpp4
-rw-r--r--ydb/core/sys_view/ut_kqp.cpp2
-rw-r--r--ydb/core/testlib/test_client.cpp46
-rw-r--r--ydb/core/testlib/test_client.h23
-rw-r--r--ydb/core/viewer/viewer_ut.cpp4
-rw-r--r--ydb/public/lib/deprecated/kicli/cpp_ut.cpp2
-rw-r--r--ydb/services/keyvalue/grpc_service_ut.cpp2
-rw-r--r--ydb/services/ydb/ydb_common_ut.h4
-rw-r--r--ydb/services/ydb/ydb_table_ut.cpp2
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();
{