diff --git a/src/test/java/org/logstash/plugins/inputs/http/util/ExecutionObserverTest.java b/src/test/java/org/logstash/plugins/inputs/http/util/ExecutionObserverTest.java
index fda18093..7d7d5b88 100644
--- a/src/test/java/org/logstash/plugins/inputs/http/util/ExecutionObserverTest.java
+++ b/src/test/java/org/logstash/plugins/inputs/http/util/ExecutionObserverTest.java
@@ -191,10 +191,10 @@ void testThreadSafetyBruteForce() {
             assertThat(maxConcurrency.get(), is(greaterThan(1)));
             assertThat(maxNodes.get(), is(lessThanOrEqualTo(concurrency * 2)));
 
-            // without queries, we should at least have some compaction
+            // without queries, we may have some compaction so we shouldn't be too strict
             final ExecutionObserver.Stats preCompactionStats = observer.stats();
             assertThat(preCompactionStats.executing, is(0));
-            assertThat(preCompactionStats.nodes, is(both(greaterThan(0)).and(lessThan((int) Math.sqrt(concurrency)))));
+            assertThat(preCompactionStats.nodes, is(both(greaterThan(0)).and(lessThan(concurrency))));
 
             // query triggers tail compaction, leaving 2 or fewer nodes.
             assertThat(observer.anyExecuting(), is(false));