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,