diff options
| -rw-r--r-- | yt/yt/core/concurrency/throughput_throttler.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/yt/yt/core/concurrency/throughput_throttler.cpp b/yt/yt/core/concurrency/throughput_throttler.cpp index c5a4e34ce67..51518b1cd48 100644 --- a/yt/yt/core/concurrency/throughput_throttler.cpp +++ b/yt/yt/core/concurrency/throughput_throttler.cpp @@ -448,7 +448,8 @@ private: YT_VERIFY(limit >= 0); // Reconfigure clears the update cookie, so infinity is fine. - auto delay = limit ? TDuration::MilliSeconds(Max<i64>(0, -Available_ * 1000 / limit)) : TDuration::Max(); + // NB: Cap by 1 ms from below to somewhat limit the wakeup rate. + auto delay = limit ? TDuration::MilliSeconds(Max<i64>(1, -Available_ * 1000 / limit)) : TDuration::Max(); UpdateCookie_ = TDelayedExecutor::Submit( BIND_NO_PROPAGATE(&TReconfigurableThroughputThrottler::Update, MakeWeak(this)), |
