Dynamic with even lower weight

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 b61a17c3fb7..eba9ab1f4bd 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;
@@ -191,7 +190,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);