(inlong) branch master updated: [INLONG-10474][Manager] Restrict sortTaskName and sortConsumeName the same with datanodeName when migrate Inlong Group (#10475)

[vernedeng]

This is an automated email from the ASF dual-hosted git repository.

vernedeng 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 e7dd1d05ef [INLONG-10474][Manager] Restrict sortTaskName and 
sortConsumeName the same with datanodeName when migrate Inlong Group (#10475)
e7dd1d05ef is described below

commit e7dd1d05ef8dc3eb012b5d3ed624595607858afc
Author: vernedeng <verned...@apache.org>
AuthorDate: Fri Jun 21 14:15:07 2024 +0800

    [INLONG-10474][Manager] Restrict sortTaskName and sortConsumeName the same 
with datanodeName when migrate Inlong Group (#10475)
    
    * [INLONG-10474][Manager] Restrict sortTaskName and sortConsumeName the 
same with datanodeName when migrate Inlong Group
---
 .../apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java
index ddc8a0fbd9..e92c3372ad 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java
@@ -272,6 +272,9 @@ public class InlongTenantServiceImpl implements 
InlongTenantService {
 
         String newName = copyDataNode(dataNodeName, type, from, to);
         sink.setDataNodeName(newName);
+        if (StringUtils.isNotBlank(sink.getSortTaskName())) {
+            sink.setSortTaskName(newName);
+        }
         return sinkMapper.updateByIdSelective(sink) == 
InlongConstants.AFFECTED_ONE_ROW;
 
     }