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 <[email protected]>
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;
}
