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

liugddx pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 1da49f5a2b [Hotfix][Clickhouse] Fix clickhouse old version 
compatibility (#5326)
1da49f5a2b is described below

commit 1da49f5a2b7130a57c881e93e54c432b76cae17b
Author: hailin0 <[email protected]>
AuthorDate: Wed Aug 23 22:59:13 2023 +0800

    [Hotfix][Clickhouse] Fix clickhouse old version compatibility (#5326)
---
 release-note.md                                                        | 1 +
 .../seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java         | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/release-note.md b/release-note.md
index 24c3f01abe..eb1624b158 100644
--- a/release-note.md
+++ b/release-note.md
@@ -15,6 +15,7 @@
 ### Connectors
 - [Elasticsearch] Support https protocol & compatible with opensearch
 - [Hbase] Add hbase sink connector #4049
+- [Clickhouse] Fix clickhouse old version compatibility #5326
 ### Formats
 - [Canal]Support read canal format message #3950
 - [Debezium]Support debezium canal format message #3981
diff --git 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java
 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java
index 235279b4d5..de29c6cf8b 100644
--- 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java
+++ 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java
@@ -208,7 +208,8 @@ public class ClickhouseSinkWriter
             }
             return false;
         } catch (SQLException e) {
-            throw new 
ClickhouseConnectorException(CommonErrorCode.SQL_OPERATION_FAILED, e);
+            log.warn("Failed to get clickhouse server config: {}", configKey, 
e);
+            return false;
         }
     }
 }

Reply via email to