This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 8cfd8b45fc [Improve][Connector-v2] add starrocks comment test (#8545)
8cfd8b45fc is described below
commit 8cfd8b45fc45962d457201e88f86a4d3475e8552
Author: corgy-w <[email protected]>
AuthorDate: Fri Jan 17 15:57:24 2025 +0800
[Improve][Connector-v2] add starrocks comment test (#8545)
---
.../java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 a575da7862..1e984205ae 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
@@ -362,7 +362,7 @@ public class StarRocksIT extends TestSuiteBase implements
TestResource {
"root",
PASSWORD,
String.format(URL, starRocksServer.getHost()),
- "CREATE TABLE IF NOT EXISTS `${database}`.`${table}`
(\n ${rowtype_fields}\n ) ENGINE=OLAP \n DUPLICATE KEY(`BIGINT_COL`) \n
DISTRIBUTED BY HASH (BIGINT_COL) BUCKETS 1 \n PROPERTIES (\n
\"replication_num\" = \"1\", \n \"in_memory\" = \"false\" , \n
\"storage_format\" = \"DEFAULT\" \n )");
+ "CREATE TABLE IF NOT EXISTS `${database}`.`${table}`
(\n ${rowtype_fields}\n ) ENGINE=OLAP \n DUPLICATE KEY(`BIGINT_COL`) \n
COMMENT '${comment}' \n DISTRIBUTED BY HASH (BIGINT_COL) BUCKETS 1 \n
PROPERTIES (\n \"replication_num\" = \"1\", \n \"in_memory\" = \"false\" ,
\n \"storage_format\" = \"DEFAULT\" \n )");
starRocksCatalog.open();
CatalogTable catalogTable =
starRocksCatalog.getTable(tablePathStarRocksSource);
// sink tableExists ?
