Less logs

5 files changed, 16 insertions, 14 deletions

diff --git a/ydb/core/yq/libs/actors/nodes_manager.cpp b/ydb/core/yq/libs/actors/nodes_manager.cpp
index 16e589a2d8..a27447517b 100644
--- a/ydb/core/yq/libs/actors/nodes_manager.cpp
+++ b/ydb/core/yq/libs/actors/nodes_manager.cpp
@@ -21,6 +21,8 @@
     LOG_INFO_S(*TlsActivationContext, NKikimrServices::YQL_NODES_MANAGER, stream)
 #define LOG_D(stream) \
     LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::YQL_NODES_MANAGER, stream)
+#define LOG_T(stream) \
+    LOG_TRACE_S(*TlsActivationContext, NKikimrServices::YQL_NODES_MANAGER, stream)
 
 namespace NYq {
 
@@ -252,7 +254,7 @@ private:
             ServiceCounters.Counters->GetCounter("PeerCount", false)->Set(Peers.size());
             ServiceCounters.Counters->GetCounter("NodesHealthCheckOk", true)->Inc();
 
-            LOG_D("Send NodeInfo with size: " << nodesInfo.size() << " to DynamicNameserver");
+            LOG_T("Send NodeInfo with size: " << nodesInfo.size() << " to DynamicNameserver");
             if (!nodesInfo.empty()) {
                 Send(GetNameserviceActorId(), nameServiceUpdateReq.Release());
             }
diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp
index 09256a129e..6ce862f973 100644
--- a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp
+++ b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp
@@ -117,7 +117,7 @@ private:
     };
 
     void OnStateRequest(TEvDqCompute::TEvStateRequest::TPtr& ev) {
-        CA_LOG_T("Got TEvStateRequest from actor " << ev->Sender << " TaskId: " << Task.GetId() << " PingCookie: " << ev->Cookie);
+        CA_LOG_T("Got TEvStateRequest from actor " << ev->Sender << " PingCookie: " << ev->Cookie);
         if (!SentStatsRequest) {
             Send(TaskRunnerActorId, new NTaskRunnerActor::TEvStatistics(GetIds(SinksMap)));
             SentStatsRequest = true;
@@ -283,7 +283,7 @@ private:
     }
 
     void TakeInputChannelData(NDqProto::TChannelData&& channelData, bool ack) override {
-        CA_LOG_D("task: " << Task.GetId() << ", took input");
+        CA_LOG_T("took input");
         TInputChannelInfo* inputChannel = InputChannelsMap.FindPtr(channelData.GetChannelId());
         YQL_ENSURE(inputChannel, "task: " << Task.GetId() << ", unknown input channelId: " << channelData.GetChannelId());
 
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
index 4c07e23a9e..f4fdf0569d 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
@@ -105,7 +105,7 @@ void TDqComputeActorChannels::HandleWork(TEvDqCompute::TEvChannelData::TPtr& ev)
 
     TInputChannelState& inputChannel = InCh(channelId);
 
-    LOG_D("Received input for channelId: " << channelId
+    LOG_T("Received input for channelId: " << channelId
         << ", seqNo: " << record.GetSeqNo()
         << ", size: " << channelData.GetData().GetRaw().size()
         << ", rows: " << channelData.GetData().GetRows()
@@ -551,7 +551,7 @@ void TDqComputeActorChannels::SendChannelData(NDqProto::TChannelData&& channelDa
     ui32 chunkRows = channelData.GetData().GetRows();
     bool finished = channelData.GetFinished();
 
-    LOG_D("SendChannelData, channelId: " << channelData.GetChannelId()
+    LOG_T("SendChannelData, channelId: " << channelData.GetChannelId()
         << ", peer: " << *outputChannel.Peer
         << ", rows: " << chunkRows
         << ", bytes: " << chunkBytes
@@ -588,7 +588,7 @@ bool TDqComputeActorChannels::PollChannel(ui64 channelId, i64 freeSpace) {
     if (!inputChannel.Peer || (inputChannel.Finished && !SupportCheckpoints) || inputChannel.RetryState ||
         inputChannel.LastRecvSeqNo == 0 || freeSpace <= 0)
     {
-        LOG_D("no poll, channelId: " << channelId << ", hasPeer: " << inputChannel.Peer.has_value()
+        LOG_T("no poll, channelId: " << channelId << ", hasPeer: " << inputChannel.Peer.has_value()
             << ", finished: " << inputChannel.Finished << ", retry: " << inputChannel.RetryState.has_value()
             << ", lastSeqNo: " << inputChannel.LastRecvSeqNo << ", freeSpace: " << freeSpace);
         return false;
@@ -598,7 +598,7 @@ bool TDqComputeActorChannels::PollChannel(ui64 channelId, i64 freeSpace) {
         if (inputChannel.PollRequest->SeqNo == inputChannel.LastRecvSeqNo &&
             inputChannel.PollRequest->FreeSpace == freeSpace)
         {
-            LOG_D("no poll, channelId: " << channelId << ", has poll request"
+            LOG_T("no poll, channelId: " << channelId << ", has poll request"
                 << " with same seqNo: " << inputChannel.PollRequest->SeqNo
                 << " and freeSpace: " << inputChannel.PollRequest->FreeSpace);
             return false;
@@ -607,7 +607,7 @@ bool TDqComputeActorChannels::PollChannel(ui64 channelId, i64 freeSpace) {
         if (!inputChannel.InFlight.empty()) {
             i64 lastFreeSpace = inputChannel.InFlight.rbegin()->second.FreeSpace;
             if (lastFreeSpace >= freeSpace) {
-                LOG_D("no poll, channelId: " << channelId
+                LOG_T("no poll, channelId: " << channelId
                     << ", has inflight messages: " << InFlightMessagesStr(inputChannel.InFlight)
                     << ", last with freeSpace: " << lastFreeSpace
                     << ", current freeSpace: " << freeSpace);
@@ -621,7 +621,7 @@ bool TDqComputeActorChannels::PollChannel(ui64 channelId, i64 freeSpace) {
 
     inputChannel.PollRequest.emplace(inputChannel.LastRecvSeqNo, freeSpace);
 
-    LOG_D("Poll input channelId: " << channelId
+    LOG_T("Poll input channelId: " << channelId
         << ", from: " << *inputChannel.Peer
         << ", seqNo: " << inputChannel.LastRecvSeqNo
         << ", freeSpace: " << freeSpace);
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
index 1925de10c3..9d7b4a7d2e 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -371,7 +371,7 @@ protected:
     void ProcessOutputsImpl(ERunStatus status) {
         ProcessOutputsState.LastRunStatus = status;
 
-        CA_LOG_D("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight );
+        CA_LOG_T("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight );
         if (ProcessOutputsState.Inflight == 0) {
             ProcessOutputsState = TProcessOutputsState();
         }
diff --git a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp
index a3cfb56a2c..c6c216fb08 100644
--- a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp
+++ b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp
@@ -156,7 +156,7 @@ public:
         const TMaybe<NDqProto::TCheckpoint>& checkpoint,
         bool finished) override
     {
-        SINK_LOG_D("Got " << batch.size() << " items to send. Checkpoint: " << checkpoint.Defined()
+        SINK_LOG_T("Got " << batch.size() << " items to send. Checkpoint: " << checkpoint.Defined()
                    << ". Send queue: " << SendingBuffer.size() << ". Inflight: " << InflightBuffer.size()
                    << ". Checkpoint in progress: " << CheckpointInProgress.has_value());
 
@@ -310,7 +310,7 @@ private:
     void PushMetricsToBuffer(ui64& metricsCount) {
         try {
             auto data = UserMetricsEncoder.Encode();
-            SINK_LOG_D("Push " << data.size() << " bytes of data to buffer");
+            SINK_LOG_T("Push " << data.size() << " bytes of data to buffer");
 
             FreeSpace -= data.size();
             SendingBuffer.emplace(TMetricsToSend { std::move(data), metricsCount });
@@ -380,7 +380,7 @@ private:
             const size_t bodySize = metricsToSend.Data.size();
             const TActorId httpSenderId = Register(CreateHttpSenderActor(SelfId(), HttpProxyId, RetryPolicy));
             Send(httpSenderId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(httpRequest), /*flags=*/0, Cookie);
-            SINK_LOG_D("Sent " << metricsToSend.MetricsCount << " metrics with size of " << metricsToSend.Data.size() << " bytes to solomon");
+            SINK_LOG_T("Sent " << metricsToSend.MetricsCount << " metrics with size of " << metricsToSend.Data.size() << " bytes to solomon");
 
             *Metrics.SentMetrics += metricsToSend.MetricsCount;
             InflightBuffer.emplace(Cookie++, TMetricsInflight { httpSenderId, metricsToSend.MetricsCount, bodySize });
@@ -401,7 +401,7 @@ private:
     }
 
     void HandleSuccessSolomonResponse(const NHttp::TEvHttpProxy::TEvHttpIncomingResponse& response, ui64 cookie) {
-        SINK_LOG_D("Solomon response[" << cookie << "]: " << response.Response->GetObfuscatedData());
+        SINK_LOG_T("Solomon response[" << cookie << "]: " << response.Response->GetObfuscatedData());
         NJson::TJsonParser parser;
         switch (WriteParams.Shard.GetClusterType()) {
             case NSo::NProto::ESolomonClusterType::CT_SOLOMON: