Merge pull request #15721 from vespa-engine/jonmv/even-softer-dynamic-throttling

Jonmv/even softer dynamic throttling

1 files changed, 4 insertions, 2 deletions

diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java
index 5c7b6839d8a..98c22884b01 100644
--- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java
+++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java
@@ -13,7 +13,6 @@ import com.yahoo.documentapi.VisitorParameters;
 import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
 import com.yahoo.jdisc.Metric;
 import com.yahoo.messagebus.DynamicThrottlePolicy;
-import com.yahoo.messagebus.StaticThrottlePolicy;
 import com.yahoo.vespa.curator.Lock;
 
 import java.time.Clock;
@@ -192,7 +191,10 @@ public class Reindexer {
 
     VisitorParameters createParameters(DocumentType type, ProgressToken progress) {
         VisitorParameters parameters = new VisitorParameters(type.getName());
-        parameters.setThrottlePolicy(new StaticThrottlePolicy().setMaxPendingCount(2));
+        parameters.setThrottlePolicy(new DynamicThrottlePolicy().setWindowSizeIncrement(0.2)
+                                                                .setWindowSizeDecrementFactor(5)
+                                                                .setResizeRate(10)
+                                                                .setMinWindowSize(1));
         parameters.setRemoteDataHandler(cluster.name());
         parameters.setMaxPending(32);
         parameters.setResumeToken(progress);