You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/07/25 02:26:30 UTC
[inlong] branch master updated: [INLONG-5163][DataProxy] Fixing Pulsar clients initialization error (#5189)
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 76bfdf2d7 [INLONG-5163][DataProxy] Fixing Pulsar clients initialization error (#5189)
76bfdf2d7 is described below
commit 76bfdf2d767845e1d5d8b8a51200e8c4f3250042
Author: woofyzhao <49...@qq.com>
AuthorDate: Mon Jul 25 10:26:26 2022 +0800
[INLONG-5163][DataProxy] Fixing Pulsar clients initialization error (#5189)
---
.../org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
index 5683c8035..ad00702d7 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
@@ -132,6 +132,7 @@ public class PulsarClientService {
}
public void initCreateConnection(CreatePulsarClientCallBack callBack) {
+ pulsarUrl2token = ConfigManager.getInstance().getMqClusterUrl2Token();
if (pulsarUrl2token == null || pulsarUrl2token.isEmpty()) {
logger.warn("failed to get Pulsar Cluster, make sure register pulsar to manager successfully.");
return;
@@ -285,7 +286,6 @@ public class PulsarClientService {
if (!pulsarClients.isEmpty()) {
return;
}
- pulsarUrl2token = ConfigManager.getInstance().getMqClusterUrl2Token();
logger.debug("number of pulsar cluster is {}", pulsarUrl2token.size());
for (Map.Entry<String, String> info : pulsarUrl2token.entrySet()) {
try {