Dynamic with even lower weight
@@ -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);
