diff options
author | jonmv <venstad@gmail.com> | 2024-05-14 22:30:01 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2024-05-14 22:30:01 +0200 |
commit | 34a1fe4950a6860d913a2c410f4d88109eced077 (patch) | |
tree | 69044a445074a0d5f1dd2a02272b3ae01e4d1bb6 /vespa-feed-client/src/main | |
parent | 830440b6978bf1c8ecef6c702e84734feb1c9a80 (diff) |
Less aggressive smoothing, and readjust a bit less often
Diffstat (limited to 'vespa-feed-client/src/main')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java | 4 |
1 files changed, 2 insertions, 2 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; |