diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2024-05-15 01:06:48 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-05-15 01:06:48 +0200 |
| commit | 63c765e1e33e02cd28f15f1a7bfad01f5f63fd43 (patch) | |
| tree | 6a3486f91ca286e792e048d0c92660eb41865da6 /vespa-feed-client/src | |
| parent | cf84c1de017cc9e3cfd1b8859ddfbfba41a350e5 (diff) | |
| parent | 34a1fe4950a6860d913a2c410f4d88109eced077 (diff) | |
Merge pull request #31203 from vespa-engine/jonmv/less-aggressive-smoothingv8.343.11
Less aggressive smoothing, and readjust a bit less often
Diffstat (limited to 'vespa-feed-client/src')
| -rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java | 4 | ||||
| -rw-r--r-- | vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/DynamicThrottlerTest.java | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java index 567788b8501..3344a372734 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java @@ -34,7 +34,7 @@ public class DynamicThrottler extends StaticThrottler { @Override public void sent(long __, CompletableFuture<HttpResponse> ___) { double currentInflight = targetInflight(); - if (++sent * sent * sent < 1e2 * currentInflight * currentInflight) + if (++sent * sent * sent < 1e3 * currentInflight * currentInflight) return; sent = 0; @@ -63,7 +63,7 @@ public class DynamicThrottler extends StaticThrottler { // Additionally, smooth the throughput values, to reduce the impact of noise, and reduce jumpiness. if (j != -1) { double t = throughputs[j]; - if (k != -1) throughputs[j] = (2 * t + throughputs[i] + s) / 4; + if (k != -1) throughputs[j] = (18 * t + throughputs[i] + s) / 20; s = t; } k = j; diff --git a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/DynamicThrottlerTest.java b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/DynamicThrottlerTest.java index 7e07fc6e116..cea5d32a55a 100644 --- a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/DynamicThrottlerTest.java +++ b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/DynamicThrottlerTest.java @@ -17,7 +17,7 @@ class DynamicThrottlerTest { DynamicThrottler throttler = new DynamicThrottler(new FeedClientBuilderImpl(List.of(URI.create("http://localhost:8080")))); assertEquals(16, throttler.targetInflight()); - for (int i = 0; i < 30; i++) { + for (int i = 0; i < 65; i++) { throttler.sent(1, null); throttler.success(); } |