[inlong] branch master updated: [INLONG-5875][Manager] Set the version for the issued sub-sources (#5877)

[do...@apache.org]

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 fc067e62f [INLONG-5875][Manager] Set the version for the issued sub-sources (#5877)
fc067e62f is described below

commit fc067e62f1a7e6a49ab25c7f83dc368718b4bb3d
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));
                 }
             }