diff options
author | jonmv <venstad@gmail.com> | 2024-04-03 15:38:52 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2024-04-03 15:38:52 +0200 |
commit | fca8615f1d69c203b5c486ba81c2d8da8384aa8b (patch) | |
tree | 06f9787f8eeec58b1fcf066a3a82909843a55b86 /vespa-feed-client | |
parent | b199f8bf2bd09f0a2fcff3dfa85861e24f69d647 (diff) |
Reduce from min 16 to 8 inflight per connection
Diffstat (limited to 'vespa-feed-client')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java index e26f4b83a1e..cc4e5edd135 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java @@ -21,7 +21,7 @@ public class StaticThrottler implements Throttler { private final AtomicLong targetX10; public StaticThrottler(FeedClientBuilderImpl builder) { - minInflight = 16L * builder.connectionsPerEndpoint * builder.endpoints.size(); + minInflight = 8L * builder.connectionsPerEndpoint * builder.endpoints.size(); maxInflight = 256 * minInflight; // 4096 max streams per connection on the server side. targetX10 = new AtomicLong(10 * maxInflight); // 10x the actual value to allow for smaller updates. } |