diff options
author | galaxycrab <UgnineSirdis@ydb.tech> | 2022-09-05 15:39:13 +0300 |
---|---|---|
committer | galaxycrab <UgnineSirdis@ydb.tech> | 2022-09-05 15:39:13 +0300 |
commit | 0f9922b1cc7d537b63655c35d597f8964b65dbf0 (patch) | |
tree | d442052a41cfb7f5532abe00c11c7dee8b9d772d | |
parent | a5b25fc153173d6b20156e9796605fdeecf25cad (diff) | |
download | ydb-0f9922b1cc7d537b63655c35d597f8964b65dbf0.tar.gz |
Add string description to "Unexpected message type" error
-rw-r--r-- | ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp | 7 |
1 files changed, 6 insertions, 1 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 55334c4daa7..7174954b936 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 @@ -46,6 +46,7 @@ #include <library/cpp/actors/core/hfunc.h> #include <util/generic/size_literals.h> +#include <util/stream/format.h> #include <queue> @@ -438,7 +439,11 @@ private: } void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> ev) final { - TString message = Sprintf("Unexpected message type 0x%08" PRIx32, ev->GetTypeRewrite()); + TStringBuilder message; + message << "S3 read. Unexpected message type " << Hex(ev->GetTypeRewrite()); + if (auto* eventBase = ev->GetBase()) { + message << " (" << eventBase->ToStringHeader() << ")"; + } Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvAsyncInputError(InputIndex, TIssues{TIssue(message)})); } private: |