aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorssmike <ssmike@ydb.tech>2023-02-07 15:09:35 +0300
committerssmike <ssmike@ydb.tech>2023-02-07 15:09:35 +0300
commitb2f3543f554e69ae2a5094c5026aa2d3fc82323d (patch)
treeadf139920e8af94195f17aa214d1a0c51e9a3baa
parent710906ce5482f1711b5ff986c2a18fef5197e196 (diff)
downloadydb-b2f3543f554e69ae2a5094c5026aa2d3fc82323d.tar.gz
Add correct actorids to logs
-rw-r--r--ydb/core/kqp/runtime/kqp_read_actor.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp
index fe0224adb3..f1b77ca372 100644
--- a/ydb/core/kqp/runtime/kqp_read_actor.cpp
+++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp
@@ -261,7 +261,7 @@ public:
NKikimrTxDataShard::TKqpReadRangesSourceSettings&& settings,
const NYql::NDq::TDqAsyncIoFactory::TSourceArguments& args)
: Settings(std::move(settings))
- , LogPrefix(TStringBuilder() << "SelfId: " << this->SelfId() << ", TxId: " << args.TxId << ", task: " << args.TaskId << ". ")
+ , LogPrefix(TStringBuilder() << "TxId: " << args.TxId << ", task: " << args.TaskId << ", CA Id" << args.ComputeActorId << ". ")
, ComputeActorId(args.ComputeActorId)
, InputIndex(args.InputIndex)
, TypeEnv(args.TypeEnv)
@@ -311,6 +311,7 @@ public:
}
void Bootstrap() {
+ LogPrefix = TStringBuilder() << "SelfId: " << this->SelfId() << ", " << LogPrefix;
THolder<TShardState> stateHolder = MakeHolder<TShardState>(Settings.GetShardIdHint());
PendingShards.PushBack(stateHolder.Get());
auto& state = *stateHolder.Release();
@@ -982,7 +983,7 @@ private:
TVector<NKikimrTxDataShard::TLock> BrokenLocks;
ui32 MaxInFlight = 1024;
- const TString LogPrefix;
+ TString LogPrefix;
TTableId TableId;
const TActorId ComputeActorId;