diff options
author | jonmv <venstad@gmail.com> | 2024-05-13 11:21:39 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2024-05-13 11:21:39 +0200 |
commit | f951681e3e1076606da092437a32c92454533e14 (patch) | |
tree | 4333d09e872ed11cf2dfd7d5a08ab6ebe219ff34 /vespa-feed-client/src/test/java/ai | |
parent | 532efd915a6604bd4a48de0de097f15cc24d4594 (diff) |
Revert "Merge pull request #31177 from vespa-engine/revert-31158-jonmv/start-lower-when-feeding"
This reverts commit dc1d2982e21098e0dee252f229762960259382ac, reversing
changes made to 1073327b4b38213311e992f2c2353a376d3404de.
Diffstat (limited to 'vespa-feed-client/src/test/java/ai')
-rw-r--r-- | vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/HttpRequestStrategyTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/HttpRequestStrategyTest.java b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/HttpRequestStrategyTest.java index 54fab9b859b..b1a04ac9ed4 100644 --- a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/HttpRequestStrategyTest.java +++ b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/HttpRequestStrategyTest.java @@ -33,6 +33,7 @@ import static ai.vespa.feed.client.FeedClient.CircuitBreaker.State.OPEN; import static java.nio.charset.StandardCharsets.UTF_8; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertFalse; +import static org.junit.jupiter.api.Assertions.assertInstanceOf; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; @@ -105,7 +106,7 @@ class HttpRequestStrategyTest { cluster.expect((__, vessel) -> vessel.completeExceptionally(new RuntimeException("boom"))); ExecutionException expected = assertThrows(ExecutionException.class, () -> strategy.enqueue(id1, request).get()); - assertTrue(expected.getCause() instanceof FeedException); + assertInstanceOf(FeedException.class, expected.getCause()); assertEquals("java.lang.RuntimeException: boom", expected.getCause().getMessage()); assertEquals(1, strategy.stats().requests()); @@ -200,7 +201,7 @@ class HttpRequestStrategyTest { @Override public int retries() { return 1; } }) .setCircuitBreaker(breaker) - .setConnectionsPerEndpoint(1), + .setConnectionsPerEndpoint(3), // Must be >= 0.5x text ops. cluster); DocumentId id1 = DocumentId.of("ns", "type", "1"); |