diff options
author | hcpp <hcpp@ydb.tech> | 2023-03-27 14:18:07 +0300 |
---|---|---|
committer | hcpp <hcpp@ydb.tech> | 2023-03-27 14:18:07 +0300 |
commit | c749f305771b334a76fe6069bb3efde650180b2e (patch) | |
tree | c38cf76be559dc27d61bfc7feedaf9e05a1293c5 | |
parent | 01710148b203237958368a84a27510de48dbb5c3 (diff) | |
download | ydb-c749f305771b334a76fe6069bb3efde650180b2e.tar.gz |
issues will move to transient_issue in case of race
-rw-r--r-- | ydb/core/fq/libs/actors/run_actor.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/fq/libs/actors/run_actor.cpp b/ydb/core/fq/libs/actors/run_actor.cpp index 6053b9c4928..d33d73587c4 100644 --- a/ydb/core/fq/libs/actors/run_actor.cpp +++ b/ydb/core/fq/libs/actors/run_actor.cpp @@ -1064,6 +1064,7 @@ private: if (Finishing && !result.issues_size()) { // Race between abort and successful finishing. Override with success and provide results to user. FinalQueryStatus = FederatedQuery::QueryMeta::COMPLETED; + TransientIssues.AddIssues(Issues); Issues.Clear(); } @@ -1700,7 +1701,7 @@ private: } { - dataProvidersInit.push_back(GetS3DataProviderInitializer(Params.S3Gateway, Params.CredentialsFactory, + dataProvidersInit.push_back(GetS3DataProviderInitializer(Params.S3Gateway, Params.CredentialsFactory, Params.Config.GetReadActorsFactoryConfig().GetS3ReadActorFactoryConfig().GetAllowLocalFiles())); } |