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/09/14 02:27:49 UTC
[inlong] 01/02: [INLONG-5875][Manager] Set the version for the issued sub-sources (#5877)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 12adab39cbad68c764d9d1d0b25bc9377bb6870b
Author: woofyzhao <49...@qq.com>
AuthorDate: Tue Sep 13 19:00:26 2022 +0800
[INLONG-5875][Manager] Set the version for the issued sub-sources (#5877)
---
.../org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
index 5e56c385d..2258581a9 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
@@ -261,6 +261,8 @@ public class AgentServiceImpl implements AgentService {
int nextStatus = getNextStatus(fileEntity.getStatus());
fileEntity.setStatus(nextStatus);
if (sourceMapper.insert(fileEntity) > 0) {
+ // refresh entity version and others.
+ fileEntity = sourceMapper.selectById(fileEntity.getId());
fileTasks.add(getDataConfig(fileEntity, op));
}
}