aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authora-romanov <a-romanov@yandex-team.ru>2022-07-01 20:00:49 +0300
committera-romanov <a-romanov@yandex-team.ru>2022-07-01 20:00:49 +0300
commit736432ded7ac5ddb4c45990816b463912041acf3 (patch)
tree65f15b9d80bebc912ffafc7299edd76f2874c449
parentb30a65cd2df15691dd97b50f1296203ea64a7be9 (diff)
downloadydb-736432ded7ac5ddb4c45990816b463912041acf3.tar.gz
YQL-15033 S3 fix logs.
ref:0435067d8d19bcaca7e0f0fa876e265e87977f72
-rw-r--r--ydb/library/yql/providers/s3/actors/yql_s3_write_actor.cpp17
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();
}