fix ci

TongchengOpenSource · Dec 8, 2024 · c102ae3 · c102ae3
1 parent cd13db4
commit c102ae3
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 21 deletions.
diff --git 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/...rg/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java b/...rg/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/...rg/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSourceTableConfig.java b/...rg/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;