diff options
author | a-romanov <a-romanov@yandex-team.ru> | 2022-07-01 20:00:49 +0300 |
---|---|---|
committer | a-romanov <a-romanov@yandex-team.ru> | 2022-07-01 20:00:49 +0300 |
commit | 736432ded7ac5ddb4c45990816b463912041acf3 (patch) | |
tree | 65f15b9d80bebc912ffafc7299edd76f2874c449 | |
parent | b30a65cd2df15691dd97b50f1296203ea64a7be9 (diff) | |
download | ydb-736432ded7ac5ddb4c45990816b463912041acf3.tar.gz |
YQL-15033 S3 fix logs.
ref:0435067d8d19bcaca7e0f0fa876e265e87977f72
-rw-r--r-- | ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp b/ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp index 79785df724b..c026e8280c8 100644 --- a/ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp +++ b/ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp @@ -158,20 +158,20 @@ private: const auto& message = root.Node("Message", true).Value<TString>(); actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << message << ", error: code: " << code)}))); } else if (root.Name() != "InitiateMultipartUploadResult") - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected response '" << root.Name() << "' on discovery.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected response '" << root.Name() << "' on create upload.")}))); else actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadStarted(root.Node("UploadId", true).Value<TString>()))); break; } catch (const std::exception& ex) { - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Error '" << ex.what() << "' on parse discovery response.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Error '" << ex.what() << "' on parse create upload response.")}))); break; } case 1U: actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError(std::get<TIssues>(std::move(result))))); break; default: - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected variant index " << result.index() << " on discovery.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected variant index " << result.index() << " on create upload response.")}))); break; } } @@ -197,26 +197,25 @@ private: const auto& message = root.Node("Message", true).Value<TString>(); actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << message << ", error: code: " << code)}))); } else if (root.Name() != "CompleteMultipartUploadResult") - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected response '" << root.Name() << "' on discovery.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected response '" << root.Name() << "' on finish upload.")}))); else actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadFinished())); break; } catch (const std::exception& ex) { - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Error '" << ex.what() << "' on parse discovery response.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Error '" << ex.what() << "' on parse finish upload response.")}))); break; } case 1U: actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError(std::get<TIssues>(std::move(result))))); break; default: - actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected variant index " << result.index() << " on discovery.")}))); + actorSystem->Send(new IEventHandle(selfId, TActorId(), new TEvPrivate::TEvUploadError({TIssue(TStringBuilder() << "Unexpected variant index " << result.index() << " on finish upload response.")}))); break; } } - void SendData(TUnboxedValueVector&& data, i64 size, const TMaybe<NDqProto::TCheckpoint>&, bool finished) final { - Cerr << __func__ << '(' << data.size() << ',' << size << ',' << finished << ')' << Endl; + void SendData(TUnboxedValueVector&& data, i64, const TMaybe<NDqProto::TCheckpoint>&, bool finished) final { InputFinished = finished; std::move(data.begin(), data.end(), std::back_inserter(Parts)); if (!UploadId.empty()) @@ -255,7 +254,7 @@ private: void HandleFinished() {} - // IActor & IDqComputeActorAsyncInput + // IActor & IDqComputeActorAsyncOutput void PassAway() override { // Is called from Compute Actor TActorBootstrapped<TS3WriteActor>::PassAway(); } |