From c102ae3614886365c3283ae12d26ac6cfe044f5e Mon Sep 17 00:00:00 2001 From: ClownXC Date: Sun, 8 Dec 2024 22:45:17 +0800 Subject: [PATCH] fix ci --- docs/en/connector-v2/source/StarRocks.md | 38 +++++++++---------- .../client/StarRocksStreamLoadVisitor.java | 1 - .../config/StarRocksSourceTableConfig.java | 3 +- 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 5609902a6cd..ae33c9233bf 100644 --- a/docs/en/connector-v2/source/StarRocks.md +++ b/docs/en/connector-v2/source/StarRocks.md @@ -19,24 +19,24 @@ delivers the query plan as a parameter to BE nodes, and then obtains data result ## Options -| name | type | required | default value | -|--------------------------|--------|----------|-------------------| -| nodeUrls | list | yes | - | -| username | string | yes | - | -| password | string | yes | - | -| database | string | yes | - | -| table | string | yes | - | -| table_list | array | yes | - | -| scan_filter | string | no | - | -| schema | config | yes | - | -| request_tablet_size | int | no | Integer.MAX_VALUE | -| scan_connect_timeout_ms | int | no | 30000 | -| scan_query_timeout_sec | int | no | 3600 | -| scan_keep_alive_min | int | no | 10 | -| scan_batch_rows | int | no | 1024 | -| scan_mem_limit | long | no | 2147483648 | -| max_retries | int | no | 3 | -| scan.params.* | string | no | - | +| name | type | required | default value | +|---------------------------|--------|----------|--------------------| +| nodeUrls | list | yes | - | +| username | string | yes | - | +| password | string | yes | - | +| database | string | yes | - | +| table | string | yes | - | +| table_list | array | yes | - | +| scan_filter | string | no | - | +| schema | config | yes | - | +| request_tablet_size | int | no | Integer.MAX_VALUE | +| scan_connect_timeout_ms | int | no | 30000 | +| scan_query_timeout_sec | int | no | 3600 | +| scan_keep_alive_min | int | no | 10 | +| scan_batch_rows | int | no | 1024 | +| scan_mem_limit | long | no | 2147483648 | +| max_retries | int | no | 3 | +| scan.params.* | string | no | - | ### nodeUrls [list] @@ -194,7 +194,7 @@ source { table_list = [ { table = "e2e_table_source" - schema { + schema = { fields { BIGINT_COL = BIGINT LARGEINT_COL = STRING diff --git a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java index 60ffd422e3b..137afb0a794 100644 --- a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java +++ b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java @@ -19,7 +19,6 @@ import org.apache.seatunnel.api.table.catalog.Column; import org.apache.seatunnel.api.table.catalog.TableSchema; -import org.apache.seatunnel.common.exception.CommonErrorCodeDeprecated; import org.apache.seatunnel.common.exception.CommonErrorCode; import org.apache.seatunnel.common.utils.JsonUtils; import org.apache.seatunnel.connectors.seatunnel.starrocks.config.SinkConfig; diff --git a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSourceTableConfig.java b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSourceTableConfig.java index e9b791e6213..86b2732bdcd 100644 --- a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSourceTableConfig.java +++ b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSourceTableConfig.java @@ -17,6 +17,8 @@ package org.apache.seatunnel.connectors.seatunnel.starrocks.config; +import org.apache.seatunnel.shade.com.google.common.collect.Lists; + import org.apache.seatunnel.api.configuration.ReadonlyConfig; import org.apache.seatunnel.api.table.catalog.CatalogTable; import org.apache.seatunnel.api.table.catalog.TableIdentifier; @@ -25,7 +27,6 @@ import org.apache.seatunnel.api.table.catalog.schema.ReadonlyConfigParser; import org.apache.seatunnel.api.table.catalog.schema.TableSchemaOptions; -import com.google.common.collect.Lists; import lombok.Getter; import java.io.Serializable;