diff options
| author | hor911 <hor911@ydb.tech> | 2023-02-15 16:36:19 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2023-02-15 16:36:19 +0300 |
| commit | a21f85ad7d3ea9b211498f3ff32968ae7da66f9a (patch) | |
| tree | d080bd4700146989920f46a89ecac8a29d323121 | |
| parent | 27e22c30b9098051f1440a1e840d29b11147a57e (diff) | |
| download | ydb-a21f85ad7d3ea9b211498f3ff32968ae7da66f9a.tar.gz | |
Disable async err w/o status code
| -rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h | 2 | ||||
| -rw-r--r-- | ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h index b823da97c27..6668be4e0aa 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h @@ -55,7 +55,7 @@ struct IDqComputeActorAsyncInput { }; struct TEvAsyncInputError : public NActors::TEventLocal<TEvAsyncInputError, TDqComputeEvents::EvAsyncInputError> { - TEvAsyncInputError(ui64 inputIndex, const TIssues& issues, NYql::NDqProto::StatusIds::StatusCode fatalCode = NYql::NDqProto::StatusIds::UNSPECIFIED) + TEvAsyncInputError(ui64 inputIndex, const TIssues& issues, NYql::NDqProto::StatusIds::StatusCode fatalCode) : InputIndex(inputIndex) , Issues(issues) , FatalCode(fatalCode) 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 e28cfe15fd4..81ba304ce2f 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 @@ -1090,7 +1090,7 @@ private: if (auto* eventBase = ev->GetBase()) { message << " (" << eventBase->ToStringHeader() << ")"; } - Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvAsyncInputError(InputIndex, TIssues{TIssue(message)})); + Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvAsyncInputError(InputIndex, TIssues{TIssue(message)}, NYql::NDqProto::StatusIds::INTERNAL_ERROR)); } TString GetLastDataAsText() { |