aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java')
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
index ad6f7225ee8..6f4e4e752f0 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
@@ -23,7 +23,7 @@ public class DynamicThrottler extends StaticThrottler {
private final AtomicLong targetInflight;
private long updateNanos = 0;
private final List<AtomicLong> latencies = new ArrayList<>();
- private final double weight = 0.8; // Higher weight favours higher (own) throughput, at the cost of (shared) latency.
+ private final double weight = 0.9; // Higher weight favours higher (own) throughput, at the cost of (shared) latency.
public DynamicThrottler(FeedClientBuilder builder) {
super(builder);
@@ -63,7 +63,7 @@ public class DynamicThrottler extends StaticThrottler {
choice = target;
}
}
- long target = (long) ((random() * 0.15 + 0.95) * choice); // Random walk, skewed towards increase.
+ long target = (long) ((random() * 0.25 + 0.90) * choice); // Random walk, skewed towards increase.
targetInflight.set(max(minInflight, min(maxInflight, target)));
});
}