From 030887f2a3d9e1d289e3a9d409dd7d54313ec82a Mon Sep 17 00:00:00 2001 From: Pisarenko Grigoriy Date: Mon, 3 Nov 2025 12:27:02 +0300 Subject: [PATCH] Improved session actor logs on query fail --- ydb/core/kqp/session_actor/kqp_session_actor.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index b61115e38a61..713ad7573e23 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -2503,7 +2503,10 @@ class TKqpSessionActor : public TActorBootstrapped, IActorExce } } - LOG_W("ReplyQueryCompileError, status " << QueryState->CompileResult->Status << " remove tx with tx_id: " << txId.GetHumanStr()); + LOG_W("ReplyQueryCompileError, status: " << QueryState->CompileResult->Status + << ", issues: " << Join(", ", QueryResponse->Record.GetResponse().GetQueryIssues()) + << ", remove tx with tx_id: " << txId.GetHumanStr()); + if (auto ctx = Transactions.ReleaseTransaction(txId)) { ctx->Invalidate(); if (!ctx->BufferActorId) { @@ -2984,7 +2987,8 @@ class TKqpSessionActor : public TActorBootstrapped, IActorExce void ReplyQueryError(Ydb::StatusIds::StatusCode ydbStatus, const TString& message, std::optional> issues = {}) { - LOG_W("Create QueryResponse for error on request, msg: " << message); + LOG_W("Create QueryResponse for error on request, msg: " << message << ", status: " << ydbStatus + << (issues ? TStringBuilder() << ", issues: " << Join(", ", *issues) : TStringBuilder())); QueryResponse = std::make_unique(); QueryResponse->Record.SetYdbStatus(ydbStatus);