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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
