This is an automated email from the ASF dual-hosted git repository.
lidongdai 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 3fe9c06e8b [Improve][Iceberg] Fix withDescription format in
IcebergSourceOptions (#10166)
3fe9c06e8b is described below
commit 3fe9c06e8b0b38557fbac5de970105864b24ac64
Author: corgy-w <[email protected]>
AuthorDate: Mon Dec 8 18:32:45 2025 +0800
[Improve][Iceberg] Fix withDescription format in IcebergSourceOptions
(#10166)
---
.../seatunnel/iceberg/config/IcebergSourceOptions.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSourceOptions.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSourceOptions.java
index a5b501b2ba..3475f7f856 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSourceOptions.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSourceOptions.java
@@ -33,50 +33,50 @@ public class IcebergSourceOptions extends
IcebergCommonOptions {
Options.key("start_snapshot_timestamp")
.longType()
.noDefaultValue()
- .withDescription(" the iceberg timestamp of starting
snapshot ");
+ .withDescription("The iceberg timestamp of starting
snapshot.");
public static final Option<Long> KEY_START_SNAPSHOT_ID =
Options.key("start_snapshot_id")
.longType()
.noDefaultValue()
- .withDescription(" the iceberg id of starting snapshot ");
+ .withDescription("The iceberg id of starting snapshot.");
public static final Option<Long> KEY_END_SNAPSHOT_ID =
Options.key("end_snapshot_id")
.longType()
.noDefaultValue()
- .withDescription(" the iceberg id of ending snapshot ");
+ .withDescription("The iceberg id of ending snapshot.");
public static final Option<Long> KEY_USE_SNAPSHOT_ID =
Options.key("use_snapshot_id")
.longType()
.noDefaultValue()
- .withDescription(" the iceberg used snapshot id");
+ .withDescription("The iceberg used snapshot id.");
public static final Option<Long> KEY_USE_SNAPSHOT_TIMESTAMP =
Options.key("use_snapshot_timestamp")
.longType()
.noDefaultValue()
- .withDescription(" the iceberg used snapshot timestamp");
+ .withDescription("The iceberg used snapshot timestamp.");
public static final Option<IcebergStreamScanStrategy>
KEY_STREAM_SCAN_STRATEGY =
Options.key("stream_scan_strategy")
.enumType(IcebergStreamScanStrategy.class)
.defaultValue(FROM_LATEST_SNAPSHOT)
- .withDescription(" the iceberg strategy of stream
scanning");
+ .withDescription("The iceberg strategy of stream
scanning.");
public static final Option<List<SourceTableConfig>> KEY_TABLE_LIST =
Options.key("table_list")
.listType(SourceTableConfig.class)
.noDefaultValue()
- .withDescription(" the iceberg tables");
+ .withDescription("The iceberg tables.");
public static final Option<Long> KEY_INCREMENT_SCAN_INTERVAL =
Options.key("increment.scan-interval")
.longType()
.defaultValue(2000L)
- .withDescription(" the interval of increment scan(mills)");
+ .withDescription("The interval of increment scan
(mills).");
public static final Option<String> QUERY =
-
Options.key("query").stringType().noDefaultValue().withDescription("the select
sql");
+
Options.key("query").stringType().noDefaultValue().withDescription("The select
sql.");
}