[inlong] branch master updated: [INLONG-6835][Manager] Fix the error about backup mq resource of DataProxy getAllConfig interface (#6836)

[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 8e4532606 [INLONG-6835][Manager] Fix the error about backup mq 
resource of DataProxy getAllConfig interface  (#6836)
8e4532606 is described below

commit 8e453260626003091713e564b98fec7dab66c395
Author: 卢春亮 <946240...@qq.com>
AuthorDate: Mon Dec 12 14:28:14 2022 +0800

    [INLONG-6835][Manager] Fix the error about backup mq resource of DataProxy 
getAllConfig interface  (#6836)
---
 .../manager/service/repository/DataProxyConfigRepository.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java
index 2a62f81f7..f9a102c31 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java
@@ -413,12 +413,12 @@ public class DataProxyConfigRepository implements 
IRepository {
 
                 Map<String, String> streamParam = streamParams.get(inlongId);
                 if (streamParam != null && 
!StringUtils.isBlank(streamParam.get(ClusterSwitch.BACKUP_MQ_RESOURCE))) {
-                    
obj.setTopic(streamParam.get(ClusterSwitch.BACKUP_MQ_RESOURCE));
+                    
backupObj.setTopic(streamParam.get(ClusterSwitch.BACKUP_MQ_RESOURCE));
                     backupObj.getParams().put(KEY_NAMESPACE, groupMqResource);
                 } else {
-                    obj.setTopic(groupMqResource);
+                    backupObj.setTopic(groupMqResource);
                 }
-                inlongIdMap.computeIfAbsent(clusterTag, k -> new 
ArrayList<>()).add(obj);
+                inlongIdMap.computeIfAbsent(clusterTag, k -> new 
ArrayList<>()).add(backupObj);
             }
         }
         return inlongIdMap;