[incubator-seatunnel] branch dev updated: [Hotfix][Connector-V2] Fix starrocks e2e bug (#3405)

[tyrantlucifer]

This is an automated email from the ASF dual-hosted git repository.

tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 187624f0c [Hotfix][Connector-V2] Fix starrocks e2e bug (#3405)
187624f0c is described below

commit 187624f0c0c90f40c49e41ab4f350051e63df210
Author: Bibo <33744252+531651...@users.noreply.github.com>
AuthorDate: Sat Nov 12 18:33:50 2022 +0800

    [Hotfix][Connector-V2] Fix starrocks e2e bug (#3405)
    
    Co-authored-by: 毕博 <b...@mafengwo.com>
---
 .../org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java  | 2 +-
 .../src/test/resources/starrocks-jdbc-to-starrocks.conf            | 7 ++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java
index e25509927..aada7404c 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java
@@ -65,7 +65,7 @@ import java.util.stream.Stream;
 public class StarRocksIT extends TestSuiteBase implements TestResource {
     private static final String DOCKER_IMAGE = 
"d87904488/starrocks-starter:2.2.1";
     private static final String DRIVER_CLASS = "com.mysql.cj.jdbc.Driver";
-    private static final String HOST = "e2e_starRocksdb";
+    private static final String HOST = "starrocks_e2e";
     private static final int SR_DOCKER_PORT = 9030;
     private static final int SR_PORT = 9033;
 
diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-jdbc-to-starrocks.conf
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-jdbc-to-starrocks.conf
index 3f8dfa33a..4cd02a03a 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-jdbc-to-starrocks.conf
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/starrocks-jdbc-to-starrocks.conf
@@ -23,7 +23,7 @@ env {
 source {
   Jdbc {
     driver = com.mysql.cj.jdbc.Driver
-    url = "jdbc:mysql://e2e_starRocksdb:9030"
+    url = "jdbc:mysql://starrocks_e2e:9030"
     user = root
     password = ""
     query = "select BIGINT_COL, LARGEINT_COL, SMALLINT_COL, TINYINT_COL, 
BOOLEAN_COL, DECIMAL_COL, DOUBLE_COL, FLOAT_COL, INT_COL, CHAR_COL, 
VARCHAR_11_COL, STRING_COL, DATETIME_COL, DATE_COL from 
`test`.`e2e_table_source`"
@@ -35,13 +35,14 @@ transform {
 
 sink {
     StarRocks {
-        nodeUrls = ["e2e_starRocksdb:8030"]
+        nodeUrls = ["starrocks_e2e:8030"]
         username = root
         password = ""
         database = "test"
         table = "e2e_table_sink"
-        batch_max_rows = 10
+        batch_max_rows = 100
         sink.properties.format = "JSON"
         sink.properties.strip_outer_array = true
+        max_retries = 3
     }
 }
\ No newline at end of file