From ca083173a9fb477722695cef25f03ad810b4f636 Mon Sep 17 00:00:00 2001 From: Hor911 Date: Mon, 22 Apr 2024 15:40:09 +0300 Subject: [PATCH] A pair of fixes (#3981) --- ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp b/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp index 8a5454368bfb..d4752920b494 100644 --- a/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp +++ b/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp @@ -1224,7 +1224,7 @@ class TS3ReadActor : public TActorBootstrapped, public IDqComputeA LOG_T("TS3ReadActor", "Handle undelivered FileQueue "); if (!FileQueueEvents.HandleUndelivered(ev)) { TIssues issues{TIssue{TStringBuilder() << "FileQueue was lost"}}; - Send(ComputeActorId, new TEvAsyncInputError(InputIndex, issues, NYql::NDqProto::StatusIds::INTERNAL_ERROR)); + Send(ComputeActorId, new TEvAsyncInputError(InputIndex, issues, NYql::NDqProto::StatusIds::UNAVAILABLE)); } } @@ -3399,12 +3399,12 @@ std::pair CreateS3ReadActor( fileQueueActor = ActorIdFromProto(protoId); } - ui64 fileQueueBatchSizeLimit; + ui64 fileQueueBatchSizeLimit = 0; if (auto it = settings.find("fileQueueBatchSizeLimit"); it != settings.cend()) { fileQueueBatchSizeLimit = FromString(it->second); } - ui64 fileQueueBatchObjectCountLimit; + ui64 fileQueueBatchObjectCountLimit = 0; if (auto it = settings.find("fileQueueBatchObjectCountLimit"); it != settings.cend()) { fileQueueBatchObjectCountLimit = FromString(it->second); }