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 ad28d5594 [INLONG-7149][Manager] Replace tableName in 
ClickHouseLoadNode with databaseName.tableName (#7150)
ad28d5594 is described below

commit ad28d5594327cb80a74501270f305b77de288cc4
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Wed Jan 4 21:20:33 2023 +0800

    [INLONG-7149][Manager] Replace tableName in ClickHouseLoadNode with 
databaseName.tableName (#7150)
---
 .../java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
index d8f47eda3..1eb3e1398 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
@@ -289,7 +289,7 @@ public class LoadNodeUtils {
                 null,
                 null,
                 properties,
-                ckSink.getTableName(),
+                ckSink.getDbName() + "." + ckSink.getTableName(),
                 ckSink.getJdbcUrl() + "/" + ckSink.getDbName(),
                 ckSink.getUsername(),
                 ckSink.getPassword(),

Reply via email to