diff options
author | ssmike <ssmike@ydb.tech> | 2023-02-07 15:09:35 +0300 |
---|---|---|
committer | ssmike <ssmike@ydb.tech> | 2023-02-07 15:09:35 +0300 |
commit | b2f3543f554e69ae2a5094c5026aa2d3fc82323d (patch) | |
tree | adf139920e8af94195f17aa214d1a0c51e9a3baa | |
parent | 710906ce5482f1711b5ff986c2a18fef5197e196 (diff) | |
download | ydb-b2f3543f554e69ae2a5094c5026aa2d3fc82323d.tar.gz |
Add correct actorids to logs
-rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 5 |
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; |