aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgalaxycrab <UgnineSirdis@ydb.tech>2022-09-05 15:39:13 +0300
committergalaxycrab <UgnineSirdis@ydb.tech>2022-09-05 15:39:13 +0300
commit0f9922b1cc7d537b63655c35d597f8964b65dbf0 (patch)
treed442052a41cfb7f5532abe00c11c7dee8b9d772d
parenta5b25fc153173d6b20156e9796605fdeecf25cad (diff)
downloadydb-0f9922b1cc7d537b63655c35d597f8964b65dbf0.tar.gz
Add string description to "Unexpected message type" error
-rw-r--r--ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp7
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: