[Improve] [Clickhouse] Remove check when set allow_experimental_light…

…weight_delete false(apache#6727) (apache#6728)
ruanwenjun · Apr 18, 2024 · b25e1b1 · b25e1b1
1 parent 8a4c01f
commit b25e1b1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...rg/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java b/...rg/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java
@@ -204,8 +204,11 @@ private Map<Shard, ClickhouseBatchStatement> initStatementMap() {
         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 + "%'");