You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/06/10 14:23:12 UTC
[incubator-inlong] 02/04: [INLONG-4622][Manager] Append db name in JDBC URL for load node (#4623)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch release-1.2.0
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit bc6c6765d4861f4586db851ebffd0b9a41bc6652
Author: lucaspeng12138 <10...@users.noreply.github.com>
AuthorDate: Fri Jun 10 20:05:03 2022 +0800
[INLONG-4622][Manager] Append db name in JDBC URL for load node (#4623)
---
.../java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java
index 5cdcfba54..e6456b78a 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java
@@ -289,7 +289,7 @@ public class LoadNodeUtils {
1,
null,
ckSink.getTableName(),
- ckSink.getJdbcUrl(),
+ ckSink.getJdbcUrl() + "/" + ckSink.getDbName(),
ckSink.getUsername(),
ckSink.getPassword()
);