From 9ea0aa493386c86df44bd27ca645fdaf3a96a551 Mon Sep 17 00:00:00 2001 From: Dmitry Kardymon Date: Wed, 20 Dec 2023 05:41:27 +0000 Subject: [PATCH] remove artifacts after other branch --- ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp b/ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp index d44002580ba8..08db4a7f0eb9 100644 --- a/ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp +++ b/ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp @@ -80,16 +80,12 @@ static void FillDefaultParameters(NConfig::TCheckpointCoordinatorConfig& checkpo auto& limits = *checkpointCoordinatorConfig.MutableStateStorageLimits(); if (!limits.GetMaxGraphCheckpointsSizeBytes()) { limits.SetMaxGraphCheckpointsSizeBytes(1099511627776); - } + } if (!limits.GetMaxTaskStateSizeBytes()) { limits.SetMaxTaskStateSizeBytes(1099511627776); } - if (!limits.GetMaxRowSizeBytes()) { - limits.SetMaxRowSizeBytes(8000000); - } - if (!checkpointCoordinatorConfig.GetStorage().GetToken() && checkpointCoordinatorConfig.GetStorage().GetOAuthFile()) { checkpointCoordinatorConfig.MutableStorage()->SetToken(StripString(TFileInput(checkpointCoordinatorConfig.GetStorage().GetOAuthFile()).ReadAll())); } @@ -119,7 +115,7 @@ void TStorageProxy::Bootstrap() { LOG_STREAMS_STORAGE_SERVICE_ERROR("Failed to init checkpoint storage: " << issues.ToOneLineString()); } - StateStorage = NewYdbStateStorage(Config, CredentialsProviderFactory, YqSharedResources); + StateStorage = NewYdbStateStorage(StorageConfig, CredentialsProviderFactory, YqSharedResources); issues = StateStorage->Init().GetValueSync(); if (!issues.Empty()) { LOG_STREAMS_STORAGE_SERVICE_ERROR("Failed to init checkpoint state storage: " << issues.ToOneLineString());