[inlong] 01/02: [INLONG-5875][Manager] Set the version for the issued sub-sources (#5877)

[dockerzhang]

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 <490467...@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));
                 }
             }