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 45f8ac6d1d [Fix][Doc] Update StarRocks doc change schema necessity to
true (#9656)
45f8ac6d1d is described below
commit 45f8ac6d1dea9097f3f5003f4dd6c9a14d17324d
Author: xiaochen <[email protected]>
AuthorDate: Mon Aug 4 13:51:39 2025 +0800
[Fix][Doc] Update StarRocks doc change schema necessity to true (#9656)
---
docs/en/connector-v2/source/StarRocks.md | 2 +-
docs/zh/connector-v2/source/StarRocks.md | 36 +++++++++++-----------
.../starrocks/source/StarRocksSourceFactory.java | 4 +--
3 files changed, 21 insertions(+), 21 deletions(-)
diff --git a/docs/en/connector-v2/source/StarRocks.md
b/docs/en/connector-v2/source/StarRocks.md
index a9e52b7e82..52e01196e6 100644
--- a/docs/en/connector-v2/source/StarRocks.md
+++ b/docs/en/connector-v2/source/StarRocks.md
@@ -29,7 +29,7 @@ delivers the query plan as a parameter to BE nodes, and then
obtains data result
| database | string | yes | - |
| table | string | no | - |
| scan_filter | string | no | - |
-| schema | config | no | - |
+| schema | config | yes | - |
| table_list | array | no | - |
| request_tablet_size | int | no | Integer.MAX_VALUE |
| scan_connect_timeout_ms | int | no | 30000 |
diff --git a/docs/zh/connector-v2/source/StarRocks.md
b/docs/zh/connector-v2/source/StarRocks.md
index 4609ce624a..89703a7db0 100644
--- a/docs/zh/connector-v2/source/StarRocks.md
+++ b/docs/zh/connector-v2/source/StarRocks.md
@@ -21,24 +21,24 @@ import ChangeLog from '../changelog/connector-starrocks.md';
## 配置选项
-| 名称 | 类型 | 是否必须 | 默认值 |
-|-------------------------|-----------|-------|-------------------|
-| nodeUrls | list | 是 | - |
-| username | string | 是 | - |
-| password | string | 是 | - |
-| database | string | 是 | - |
-| table | string | 否 | - |
-| scan_filter | string | 否 | - |
-| schema | config | 否 | - |
-| table_list | array | 否 | - |
-| request_tablet_size | int | 否 | Integer.MAX_VALUE |
-| scan_connect_timeout_ms | int | 否 | 30000 |
-| scan_query_timeout_sec | int | 否 | 3600 |
-| scan_keep_alive_min | int | 否 | 10 |
-| scan_batch_rows | int | 否 | 1024 |
-| scan_mem_limit | long | 否 | 2147483648 |
-| max_retries | int | 否 | 3 |
-| scan.params.* | string | 否 | - |
+| 名称 | 类型 | 是否必须 | 默认值 |
+|-------------------------|-----------|------|-------------------|
+| nodeUrls | list | 是 | - |
+| username | string | 是 | - |
+| password | string | 是 | - |
+| database | string | 是 | - |
+| table | string | 否 | - |
+| scan_filter | string | 否 | - |
+| schema | config | 是 | - |
+| table_list | array | 否 | - |
+| request_tablet_size | int | 否 | Integer.MAX_VALUE |
+| scan_connect_timeout_ms | int | 否 | 30000 |
+| scan_query_timeout_sec | int | 否 | 3600 |
+| scan_keep_alive_min | int | 否 | 10 |
+| scan_batch_rows | int | 否 | 1024 |
+| scan_mem_limit | long | 否 | 2147483648 |
+| max_retries | int | 否 | 3 |
+| scan.params.* | string | 否 | - |
### nodeUrls [list]
diff --git
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceFactory.java
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceFactory.java
index d0ffff5f5e..fadcfe6320 100644
---
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceFactory.java
+++
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceFactory.java
@@ -19,7 +19,7 @@ package
org.apache.seatunnel.connectors.seatunnel.starrocks.source;
import org.apache.seatunnel.api.configuration.ReadonlyConfig;
import org.apache.seatunnel.api.configuration.util.OptionRule;
-import org.apache.seatunnel.api.options.SinkConnectorCommonOptions;
+import org.apache.seatunnel.api.options.ConnectorCommonOptions;
import org.apache.seatunnel.api.source.SeaTunnelSource;
import org.apache.seatunnel.api.source.SourceSplit;
import org.apache.seatunnel.api.table.connector.TableSource;
@@ -50,7 +50,7 @@ public class StarRocksSourceFactory implements
TableSourceFactory {
StarRocksSourceOptions.PASSWORD,
StarRocksSourceOptions.DATABASE)
.optional(
- SinkConnectorCommonOptions.SCHEMA,
+ ConnectorCommonOptions.SCHEMA,
StarRocksSourceOptions.MAX_RETRIES,
StarRocksSourceOptions.QUERY_TABLET_SIZE,
StarRocksSourceOptions.SCAN_FILTER,
