[inlong] branch master updated: [INLONG-7823][Manager] Supports creating clickhouse tables using the ReplicatedMergeTree engine (#7824)

[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 620623d04 [INLONG-7823][Manager] Supports creating clickhouse tables 
using the ReplicatedMergeTree engine (#7824)
620623d04 is described below

commit 620623d04c788ed0d6381a4174f921822e169cb0
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Wed Apr 12 14:25:53 2023 +0800

    [INLONG-7823][Manager] Supports creating clickhouse tables using the 
ReplicatedMergeTree engine (#7824)
---
 .../manager/service/resource/sink/ck/ClickHouseSqlBuilder.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/ck/ClickHouseSqlBuilder.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/ck/ClickHouseSqlBuilder.java
index d17c77066..575232620 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/ck/ClickHouseSqlBuilder.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/ck/ClickHouseSqlBuilder.java
@@ -25,6 +25,7 @@ import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * Builder for ClickHouse SQL string
@@ -66,7 +67,10 @@ public class ClickHouseSqlBuilder {
         }
         // Construct columns and partition columns
         sql.append(buildCreateColumnsSql(table.getFieldInfoList()));
-        if (StringUtils.isNotEmpty(table.getEngine())) {
+        if (StringUtils.isNotBlank(table.getEngine()) && 
Objects.equals("ReplicatedMergeTree", table.getEngine())) {
+            sql.append(
+                    " ENGINE = 
ReplicatedMergeTree('/clickhouse/tables/{shard}/{database}/{table}/data', 
'{replica}')");
+        } else if (StringUtils.isNotBlank(table.getEngine())) {
             sql.append(" ENGINE = ").append(table.getEngine());
         } else {
             sql.append(" ENGINE = MergeTree()");