diff options
author | nadya73 <[email protected]> | 2025-07-12 16:46:09 +0300 |
---|---|---|
committer | nadya73 <[email protected]> | 2025-07-12 17:03:25 +0300 |
commit | d28a870061b49d7c985cd453eb01954173e4ffd0 (patch) | |
tree | 879670c39092dfcab94f79fc0a46d43b18957c27 | |
parent | b1acfe927c4ba28fce6a5cd0f36cd211f0cae5ec (diff) |
YT-25642: Don't throw error in RPC client if there is no more memory
commit_hash:689c46e5c94bad44dbba650a768d9bc68e447c65
-rw-r--r-- | yt/yt/core/rpc/bus/channel.cpp | 22 |
1 files changed, 5 insertions, 17 deletions
diff --git a/yt/yt/core/rpc/bus/channel.cpp b/yt/yt/core/rpc/bus/channel.cpp index e6c5dc1220b..77acf3f76a5 100644 --- a/yt/yt/core/rpc/bus/channel.cpp +++ b/yt/yt/core/rpc/bus/channel.cpp @@ -962,23 +962,11 @@ private: } if (error.IsOK()) { message = TrackMemory(MemoryUsageTracker_, std::move(message)); - if (MemoryUsageTracker_->IsExceeded()) { - auto error = TError( - NRpc::EErrorCode::ResponseMemoryPressure, - "Response is dropped due to high memory pressure"); - requestControl->ProfileError(error); - NotifyError( - requestControl, - responseHandler, - TStringBuf("Response is dropped due to high memory pressure"), - error); - } else { - NotifyResponse( - requestId, - requestControl, - responseHandler, - std::move(message)); - } + NotifyResponse( + requestId, + requestControl, + responseHandler, + std::move(message)); } else { requestControl->ProfileError(error); if (error.GetCode() == EErrorCode::PoisonPill) { |