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(),