[Fix] update response code for try connection (#489)

apache · Sep 14, 2024 · d7323aa · d7323aa
1 parent 62360c7
commit d7323aa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
@@ -108,7 +108,8 @@ public static boolean tryHttpConnection(String host) {
             int responseCode = connection.getResponseCode();
             String responseMessage = connection.getResponseMessage();
             connection.disconnect();
-            if (200 == responseCode) {
+            if (responseCode < 500) {
+                // code greater than 500 means a server-side exception.
                 return true;
             }
             LOG.warn(