correct logging

1 files changed, 1 insertions, 1 deletions

diff --git a/ydb/services/persqueue_v1/actors/write_session_actor.cpp b/ydb/services/persqueue_v1/actors/write_session_actor.cpp
index eb99065dc27..0152db3e555 100644
--- a/ydb/services/persqueue_v1/actors/write_session_actor.cpp
+++ b/ydb/services/persqueue_v1/actors/write_session_actor.cpp
@@ -531,7 +531,7 @@ void TWriteSessionActor::Handle(NKqp::TEvKqp::TEvQueryResponse::TPtr &ev, const
 
     if (record.GetYdbStatus() != Ydb::StatusIds::SUCCESS) {
         TStringBuilder errorReason;
-        errorReason << "internal error in kqp Marker# PQ50 : " <<  record;
+        errorReason << "kqp error Marker# PQ50 : " <<  record;
         if (State == EState::ES_INITED) {
             LOG_WARN_S(ctx, NKikimrServices::PQ_WRITE_PROXY, errorReason);
             SourceIdUpdatesInflight--;