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 6e9fa23720 [INLONG-8400][Manager] Fix the streamSource with no
data_node_name has been incorrectly modified (#8401)
6e9fa23720 is described below
commit 6e9fa23720ff22c4fe585afa1fca705e10c1837f
Author: fuweng11 <[email protected]>
AuthorDate: Mon Jul 3 16:32:11 2023 +0800
[INLONG-8400][Manager] Fix the streamSource with no data_node_name has been
incorrectly modified (#8401)
---
.../apache/inlong/manager/service/node/AbstractDataNodeOperator.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java
index 33deda1a64..9344c5e2e0 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java
@@ -31,6 +31,7 @@ import
org.apache.inlong.manager.dao.mapper.StreamSourceEntityMapper;
import org.apache.inlong.manager.pojo.node.DataNodeInfo;
import org.apache.inlong.manager.pojo.node.DataNodeRequest;
+import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -115,6 +116,10 @@ public abstract class AbstractDataNodeOperator implements
DataNodeOperator {
LOGGER.info("begin to update stream source status by dataNodeName={},
status={}, by operator={}",
dataNodeName, status, operator);
List<Integer> needUpdateIds =
sourceMapper.selectNeedUpdateIdsByClusterAndDataNode(null, dataNodeName, type);
+ if (CollectionUtils.isEmpty(needUpdateIds)) {
+ LOGGER.warn("no found stream source by dataNodeName = {}",
dataNodeName);
+ return;
+ }
try {
sourceMapper.updateStatusByIds(needUpdateIds, status, operator);
LOGGER.info("success to update stream source status by
dataNodeName={}, status={}, by operator={}",
