(inlong) branch master updated: [INLONG-10265][Manager] Fix the problem of correct wrong starrocks create table statement (#10276)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 879bf36017 [INLONG-10265][Manager] Fix the problem of correct wrong 
starrocks create table statement (#10276)
879bf36017 is described below

commit 879bf360177869f8ab179b124aea3692638a8543
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Tue May 28 10:13:32 2024 +0800

    [INLONG-10265][Manager] Fix the problem of correct wrong starrocks create 
table statement (#10276)
---
 .../service/resource/sink/starrocks/StarRocksSqlBuilder.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/starrocks/StarRocksSqlBuilder.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/starrocks/StarRocksSqlBuilder.java
index b1a1089cbe..15b2168452 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/starrocks/StarRocksSqlBuilder.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/starrocks/StarRocksSqlBuilder.java
@@ -54,11 +54,6 @@ public class StarRocksSqlBuilder {
         sql.append("CREATE TABLE ").append(table.getTableName());
         // Construct columns and partition columns
         sql.append(getColumnsAndComments(table));
-        if (!StringUtils.isEmpty(table.getPrimaryKey())) {
-            sql.append(" PRIMARY KEY (")
-                    .append(table.getPrimaryKey())
-                    .append(")");
-        }
         if (!Objects.isNull(table.getReplicationNum())) {
             sql.append(" PROPERTIES ( \"replication_num\" = \"")
                     .append(table.getReplicationNum())
@@ -161,6 +156,11 @@ public class StarRocksSqlBuilder {
             columnList.add(columnStr.toString());
         }
         StringBuilder result = new StringBuilder().append(" 
(").append(StringUtils.join(columnList, ",")).append(") ");
+        if (StringUtils.isNotBlank(tableInfo.getPrimaryKey())) {
+            result.append("PRIMARY KEY (")
+                    .append(tableInfo.getPrimaryKey())
+                    .append(") ");
+        }
         // set partitions
         if (sortKeyList.size() > 0) {
             result.append("DUPLICATE KEY 
(").append(StringUtils.join(sortKeyList, ",")).append(") ");