Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
Loading