diff --git a/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/http/netty4/Netty4HttpRequestSizeLimitIT.java b/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/http/netty4/Netty4HttpRequestSizeLimitIT.java index 0a257f89fe258..e075c2c9b8f5a 100644 --- a/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/http/netty4/Netty4HttpRequestSizeLimitIT.java +++ b/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/http/netty4/Netty4HttpRequestSizeLimitIT.java @@ -94,7 +94,9 @@ public void testLimitsInFlightRequests() throws Exception { } List> requests = new ArrayList<>(); - for (int i = 0; i < 150; i++) { + // See please https://github.com/netty/netty/pull/17068 why 128 is the cap, we should be able to + // make it configurable in the Netty next release. + for (int i = 0; i < 128; i++) { requests.add(Tuple.tuple("/index/_bulk", bulkRequest)); }