diff options
| author | hor911 <hor911@ydb.tech> | 2023-03-17 14:00:24 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2023-03-17 14:00:24 +0300 |
| commit | 8acbe8ab80fa582c4fed944164e0781bb518a2fe (patch) | |
| tree | faeaddc698785c5c988772ad3c6e91f5e26de446 | |
| parent | 00b4742f37cc92a223d788bde49f90301d8ee487 (diff) | |
| download | ydb-8acbe8ab80fa582c4fed944164e0781bb518a2fe.tar.gz | |
Don't repeat drain messages in DEBUG logs
3 files changed, 4 insertions, 1 deletions
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 6e8e87cf3fe..58461711dbf 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 @@ -225,7 +225,8 @@ private: if (Y_UNLIKELY(outputChannel.Stats)) { outputChannel.Stats->BlockedByCapacity++; } - CA_LOG_D("Can not drain channel because it is blocked by capacity. ChannelId: " << channelId + CA_LOG(peerState.PeerFreeSpace == peerState.PrevPeerFreeSpace ? NActors::NLog::PRI_TRACE : NActors::NLog::PRI_DEBUG, + "Can not drain channel because it is blocked by capacity. ChannelId: " << channelId << ". To send: " << toSend << ". Free space: " << peerState.PeerFreeSpace << ". Inflight: " << peerState.InFlightBytes 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 e4c6b2f8558..6bd3bdf0303 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 @@ -196,6 +196,7 @@ void TDqComputeActorChannels::HandleWork(TEvDqCompute::TEvChannelDataAck::TPtr& it = outputChannel.InFlight.erase(it); } + outputChannel.PeerState.PrevPeerFreeSpace = outputChannel.PeerState.PeerFreeSpace; outputChannel.PeerState.PeerFreeSpace = record.GetFreeSpace(); LOG_T("PeerState, freeSpace: " << outputChannel.PeerState.PeerFreeSpace diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h index aa15ccb18e4..f2e893bc240 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h @@ -16,6 +16,7 @@ public: ui64 InFlightBytes = 0; ui64 InFlightRows = 0; ui32 InFlightCount = 0; + i64 PrevPeerFreeSpace = 0; }; struct ICallbacks { |