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

corgy 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 fbdf39ebf2 [Improve] Remove useless iceberg sink config 
`iceberg.table.config` (#9307)
fbdf39ebf2 is described below

commit fbdf39ebf2d5574a0478e33a786221ee93d8402c
Author: Jia Fan <[email protected]>
AuthorDate: Wed May 14 01:23:43 2025 +0800

    [Improve] Remove useless iceberg sink config `iceberg.table.config` (#9307)
---
 .../connectors/seatunnel/iceberg/config/IcebergSinkOptions.java     | 6 ------
 .../connectors/seatunnel/iceberg/sink/IcebergSinkFactory.java       | 1 -
 2 files changed, 7 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSinkOptions.java
 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSinkOptions.java
index b8b4afa3f3..8557b90374 100644
--- 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSinkOptions.java
+++ 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSinkOptions.java
@@ -29,12 +29,6 @@ import java.util.Map;
 
 public class IcebergSinkOptions extends IcebergCommonOptions {
 
-    public static final Option<Map<String, String>> TABLE_PROPS =
-            Options.key("iceberg.table.config")
-                    .mapType()
-                    .defaultValue(new HashMap<>())
-                    .withDescription("Iceberg table configs");
-
     public static final Option<Map<String, String>> WRITE_PROPS =
             Options.key("iceberg.table.write-props")
                     .mapType()
diff --git 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkFactory.java
 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkFactory.java
index 2737a2b96a..cb2347d074 100644
--- 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkFactory.java
+++ 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkFactory.java
@@ -52,7 +52,6 @@ public class IcebergSinkFactory implements TableSinkFactory {
                         IcebergSinkOptions.KEY_TABLE,
                         IcebergSinkOptions.CATALOG_PROPS)
                 .optional(
-                        IcebergSinkOptions.TABLE_PROPS,
                         IcebergSinkOptions.HADOOP_PROPS,
                         IcebergSinkOptions.HADOOP_CONF_PATH_PROP,
                         IcebergSinkOptions.KEY_CASE_SENSITIVE,

Reply via email to