Skip to content

Commit 862c3c5

Browse files
Hor911uzhastik
authored andcommitted
A pair of fixes (#3981)
1 parent f4c51cc commit 862c3c5

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1224,7 +1224,7 @@ class TS3ReadActor : public TActorBootstrapped<TS3ReadActor>, public IDqComputeA
12241224
LOG_T("TS3ReadActor", "Handle undelivered FileQueue ");
12251225
if (!FileQueueEvents.HandleUndelivered(ev)) {
12261226
TIssues issues{TIssue{TStringBuilder() << "FileQueue was lost"}};
1227-
Send(ComputeActorId, new TEvAsyncInputError(InputIndex, issues, NYql::NDqProto::StatusIds::INTERNAL_ERROR));
1227+
Send(ComputeActorId, new TEvAsyncInputError(InputIndex, issues, NYql::NDqProto::StatusIds::UNAVAILABLE));
12281228
}
12291229
}
12301230

@@ -3399,12 +3399,12 @@ std::pair<NYql::NDq::IDqComputeActorAsyncInput*, IActor*> CreateS3ReadActor(
33993399
fileQueueActor = ActorIdFromProto(protoId);
34003400
}
34013401

3402-
ui64 fileQueueBatchSizeLimit;
3402+
ui64 fileQueueBatchSizeLimit = 0;
34033403
if (auto it = settings.find("fileQueueBatchSizeLimit"); it != settings.cend()) {
34043404
fileQueueBatchSizeLimit = FromString<ui64>(it->second);
34053405
}
34063406

3407-
ui64 fileQueueBatchObjectCountLimit;
3407+
ui64 fileQueueBatchObjectCountLimit = 0;
34083408
if (auto it = settings.find("fileQueueBatchObjectCountLimit"); it != settings.cend()) {
34093409
fileQueueBatchObjectCountLimit = FromString<ui64>(it->second);
34103410
}

0 commit comments

Comments
 (0)