diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-21 11:39:17 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-06-21 11:39:17 +0200 |
commit | 5889ad8c4155798a3f4d3ed1ff57bd1d34a61c42 (patch) | |
tree | d7123e4b6d91c2f56304b066bef5edef100ddeba | |
parent | 1fd7aa975463ffc97e13dbfc7a862703b623c356 (diff) | |
parent | 05584e3c36dda74570e4b95044eb39f485e4f484 (diff) |
Merge pull request #18334 from vespa-engine/jonmv/vespa-feed-client
More aggressive default settings
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java | 4 | ||||
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java | 2 |
2 files changed, 3 insertions, 3 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))); }); } diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java index 8b5eb9efea7..0f685ec5b7f 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java @@ -35,7 +35,7 @@ public class FeedClientBuilder { SSLContext sslContext; HostnameVerifier hostnameVerifier; int connectionsPerEndpoint = 4; - int maxStreamsPerConnection = 128; + int maxStreamsPerConnection = 4096; FeedClient.RetryStrategy retryStrategy = defaultRetryStrategy; FeedClient.CircuitBreaker circuitBreaker = new GracePeriodCircuitBreaker(Duration.ofSeconds(1), Duration.ofMinutes(10)); Path certificateFile; |