From a1d821695c00acbf9c147d1ae1ecd43f66a13d2b Mon Sep 17 00:00:00 2001
From: Pooya Salehi <pxsalehi@users.noreply.github.com>
Date: Mon, 21 Oct 2024 13:01:58 +0200
Subject: [PATCH] Always flush response body in
 AbstractBlobContainerRetriesTestCase#sendIncompleteContent with JDK23
 (#115197)

Resolves https://github.com/elastic/elasticsearch/issues/115172
---
 .../blobstore/AbstractBlobContainerRetriesTestCase.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/test/framework/src/main/java/org/elasticsearch/repositories/blobstore/AbstractBlobContainerRetriesTestCase.java b/test/framework/src/main/java/org/elasticsearch/repositories/blobstore/AbstractBlobContainerRetriesTestCase.java
index 90c621c62c305..12094b31a049d 100644
--- a/test/framework/src/main/java/org/elasticsearch/repositories/blobstore/AbstractBlobContainerRetriesTestCase.java
+++ b/test/framework/src/main/java/org/elasticsearch/repositories/blobstore/AbstractBlobContainerRetriesTestCase.java
@@ -418,7 +418,9 @@ protected int sendIncompleteContent(HttpExchange exchange, byte[] bytes) throws
         if (bytesToSend > 0) {
             exchange.getResponseBody().write(bytes, rangeStart, bytesToSend);
         }
-        if (randomBoolean()) {
+        if (randomBoolean() || Runtime.version().feature() >= 23) {
+            // For now in JDK23 we need to always flush. See https://bugs.openjdk.org/browse/JDK-8331847.
+            // TODO: remove the JDK version check once that issue is fixed
             exchange.getResponseBody().flush();
         }
         return bytesToSend;