This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 b25e1b1ae5 [Improve] [Clickhouse] Remove check when set
allow_experimental_lightweight_delete false(#6727) (#6728)
b25e1b1ae5 is described below
commit b25e1b1ae5d8585b5e791ceb4fc35d095ac46c31
Author: Assert <[email protected]>
AuthorDate: Thu Apr 18 15:55:00 2024 +0800
[Improve] [Clickhouse] Remove check when set
allow_experimental_lightweight_delete false(#6727) (#6728)
---
.../seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
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 96d17d341b..74119d5b46 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
@@ -204,8 +204,11 @@ public class ClickhouseSinkWriter
return result;
}
- private static boolean clickhouseServerEnableExperimentalLightweightDelete(
+ private boolean clickhouseServerEnableExperimentalLightweightDelete(
ClickHouseConnectionImpl clickhouseConnection) {
+ if (!option.isAllowExperimentalLightweightDelete()) {
+ return false;
+ }
String configKey = "allow_experimental_lightweight_delete";
try (Statement stmt = clickhouseConnection.createStatement()) {
ResultSet resultSet = stmt.executeQuery("SHOW SETTINGS ILIKE '%" +
configKey + "%'");
