(doris-flink-connector) branch master updated: [Fix] update response code for try connection (#489)

[diwu]

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new d7323aaf [Fix] update response code for try connection (#489)
d7323aaf is described below

commit d7323aaff5a67bed8c63624738f06109af1cdd89
Author: wudi <676366...@qq.com>
AuthorDate: Sat Sep 14 16:02:11 2024 +0800

    [Fix] update response code for try connection (#489)
---
 .../src/main/java/org/apache/doris/flink/sink/BackendUtil.java         | 3 ++-
 1 file changed, 2 insertions(+), 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
index 987ec9a1..26771c9d 100644
--- 
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 class BackendUtil {
             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(


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org