From d5fee69f4e65d402bd1dc9444184f73dedafbf5c Mon Sep 17 00:00:00 2001 From: Yang Xiufeng Date: Wed, 12 Nov 2025 10:22:55 +0800 Subject: [PATCH] fix: start query retry on EOFException. --- .../src/main/java/com/databend/jdbc/DatabendConnection.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java index 2244e250..1fa2334a 100644 --- a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java +++ b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java @@ -790,6 +790,12 @@ private boolean shouldRetryException(Exception e) { return true; } + if (e instanceof IOException) { + return (e.getMessage().contains("unexpected end of stream") || + e.getMessage().contains("timeout") || + e.getMessage().contains("connection refused")); + } + if (e instanceof RuntimeException) { String message = e.getMessage(); return message != null && (