diff options
| author | yumkam <yumkam7@ydb.tech> | 2025-02-13 16:44:49 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-02-13 16:44:49 +0300 |
| commit | dc604a5cac1cdec26d89eb813623f25c36d69da5 (patch) | |
| tree | eddd432011714a37346cc76d26ffd6f73f68b07d | |
| parent | edca46b352340ca9aba0b3fcaeb5810639a30d60 (diff) | |
| download | ydb-dc604a5cac1cdec26d89eb813623f25c36d69da5.tar.gz | |
pq write: pass query/task info into sdk logs (#14477)
Co-authored-by: Bulat <bylatgr@gmail.com>
| -rw-r--r-- | ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp | 1 | ||||
| -rw-r--r-- | ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp index 85b02502cc..a43c98ad57 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp @@ -297,6 +297,7 @@ private: NYdb::NTopic::TWriteSessionSettings GetWriteSessionSettings() { return NYdb::NTopic::TWriteSessionSettings(SinkParams.GetTopicPath(), GetSourceId(), GetSourceId()) + .TraceId(LogPrefix) .MaxMemoryUsage(FreeSpace) .Codec(SinkParams.GetClusterType() == NPq::NProto::DataStreams ? NYdb::NTopic::ECodec::RAW diff --git a/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp b/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp index 369e7d3b93..6a0b40faae 100644 --- a/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp +++ b/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp @@ -988,6 +988,7 @@ TStringBuilder TWriteSessionImpl::LogPrefixImpl() const { Y_ABORT_UNLESS(Lock.IsLocked()); TStringBuilder ret; + ret << " TraceId [" << Settings.TraceId_ << "] ";; ret << " SessionId [" << SessionId << "] "; if (Settings.PartitionId_.has_value() || DirectWriteToPartitionId.has_value()) { |