Fixes

shnikd · May 22, 2024 · bc6284a · bc6284a
1 parent 7febf9d
commit bc6284a
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/ydb/core/kqp/rm_service/kqp_resource_info_exchanger.cpp b/ydb/core/kqp/rm_service/kqp_resource_info_exchanger.cpp
@@ -632,10 +632,8 @@ class TKqpResourceInfoExchangerActor : public TActorBootstrapped<TKqpResourceInf
         ui64 nodesCount = NodesState.size();
         if (nodesCount >= 1000) {
             ui64 nodesCount = NodesState.size();
-            if (nodesCount >= 1000) {
-                ui64 newCurrentDelay = (nodesCount * nodesCount) >> 11;
-                CurrentNodesDelay = std::max(CurrentNodesDelay, TDuration::MilliSeconds(newCurrentDelay));
-            }
+            ui64 newCurrentDelay = (nodesCount * nodesCount) >> 11;
+            CurrentNodesDelay = std::max(CurrentNodesDelay, TDuration::MilliSeconds(newCurrentDelay));
         }
     }
 
@@ -779,7 +777,7 @@ class TKqpResourceInfoExchangerActor : public TActorBootstrapped<TKqpResourceInf
     TIntrusivePtr<TKqpCounters> Counters;
     NKikimrConfig::TTableServiceConfig::TResourceManager::TInfoExchangerSettings Settings;
 
-    TDuration CurrentNodesDelay = TDuration::MilliSeconds(500);
+    TDuration CurrentNodesDelay = TDuration::Zero();
 };
 
 NActors::IActor* CreateKqpResourceInfoExchangerActor(TIntrusivePtr<TKqpCounters> counters,