diff options
author | hor911 <[email protected]> | 2023-05-09 11:40:26 +0300 |
---|---|---|
committer | hor911 <[email protected]> | 2023-05-09 11:40:26 +0300 |
commit | 836392678a6bc233288b312c4953fffcf646b8fc (patch) | |
tree | de30961a8748f40cfc151a984752738dc471ec7b | |
parent | 0e76812af073f4215087ba85c7a47149f6029f5b (diff) |
Decrease level of repeated logs to TRACE
-rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h | 6 |
1 files changed, 3 insertions, 3 deletions
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 d78e50d9973..6fb88ba70d7 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 @@ -389,7 +389,7 @@ protected: ProcessOutputsState.ChannelsReady = false; ProcessOutputsState.HasDataToSend = true; ProcessOutputsState.AllOutputsFinished = false; - CA_LOG_D("Can not drain channelId: " << channelId << ", no dst actor id"); + CA_LOG_T("Can not drain channelId: " << channelId << ", no dst actor id"); if (Y_UNLIKELY(outputChannel.Stats)) { outputChannel.Stats->NoDstActorId++; } @@ -404,7 +404,7 @@ protected: ProcessOutputsState.HasDataToSend |= !outputChannel.Finished; } } else { - CA_LOG_D("Do not drain channelId: " << channelId << ", finished"); + CA_LOG_T("Do not drain channelId: " << channelId << ", finished"); ProcessOutputsState.AllOutputsFinished &= outputChannel.Finished; } } @@ -1333,7 +1333,7 @@ private: bool hasCheckpoint = channel->Pop(checkpoint); if (!hasData && !hasWatermark && !hasCheckpoint) { if (!channel->IsFinished()) { - CA_LOG_D("output channelId: " << channel->GetChannelId() << ", nothing to send and is not finished"); + CA_LOG_T("output channelId: " << channel->GetChannelId() << ", nothing to send and is not finished"); return 0; // channel is empty and not finished yet } } |