diff --git a/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/ServerErrorAckTerminalTest.java b/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/ServerErrorAckTerminalTest.java index 13998096..fdc9c90d 100644 --- a/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/ServerErrorAckTerminalTest.java +++ b/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/ServerErrorAckTerminalTest.java @@ -78,7 +78,12 @@ public void testServerErrorAckIsTerminalAndDoesNotBurnReconnectBudget() throws E Sender sender = Sender.fromConfig(cfg); try { sender.table("foo").longColumn("v", 1L).atNow(); - sender.flush(); + try { + sender.flush(); + } catch (LineSenderException ignored) { + // The error ACK may arrive before flush() checks for errors. + // The terminal error is sticky; the next call must still throw. + } // Wait for the server to actually receive the batch and // for the error-ACK round-trip to complete.