aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhcpp <hcpp@ydb.tech>2023-03-27 14:18:07 +0300
committerhcpp <hcpp@ydb.tech>2023-03-27 14:18:07 +0300
commitc749f305771b334a76fe6069bb3efde650180b2e (patch)
treec38cf76be559dc27d61bfc7feedaf9e05a1293c5
parent01710148b203237958368a84a27510de48dbb5c3 (diff)
downloadydb-c749f305771b334a76fe6069bb3efde650180b2e.tar.gz
issues will move to transient_issue in case of race
-rw-r--r--ydb/core/fq/libs/actors/run_actor.cpp3
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()));
}