Skip to content

Commit

Permalink
remove artifacts after other branch
Browse files Browse the repository at this point in the history
  • Loading branch information
kardymonds committed Dec 20, 2023
1 parent 6977e0f commit 9ea0aa4
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions ydb/core/fq/libs/checkpoint_storage/storage_proxy.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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()));
}
Expand Down Expand Up @@ -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());
Expand Down

0 comments on commit 9ea0aa4

Please sign in to comment.