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);