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;
}
}
}