The GitHub Actions job "Flink CI (beta)" on flink.git/master has failed. Run started by GitHub user MartijnVisser (triggered by MartijnVisser).
Head commit for run: 5cb890d408ceb4dd7cbd0960528892ca0d82642b / Martijn Visser <[email protected]> [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown (#27708) * [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown causing flaky test Change thenAccept to thenCompose in AbstractRestHandler.respondToRequest() so that the returned future only completes after the HTTP response is fully flushed to the network. Previously, the future returned by HandlerUtils.sendResponse() was silently discarded, allowing InFlightRequestTracker.deregisterRequest() to fire before the response write completed. Under load this let shutDownInternal() tear down the Netty event loops while response bytes were still in flight, causing ConnectionClosedException on the client side. * [FLINK-34644][sql-gateway] Apply same thenAccept to thenCompose fix in AbstractSqlGatewayRestHandler Apply the same fix as AbstractRestHandler: change thenAccept to thenCompose in respondToRequest() so the returned future only completes after the HTTP response is fully flushed. This prevents the same race condition where in-flight request deregistration could fire before the response write completes. Report URL: https://github.com/apache/flink/actions/runs/22521745048 With regards, GitHub Actions via GitBox
