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 01ec14730 [INLONG-6568][Manager] Fix the problem that the status of 
the deleted source was incorrectly modified (#6569)
01ec14730 is described below

commit 01ec1473047b50fb31187c0c79899b17f47d6538
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Thu Nov 17 18:36:07 2022 +0800

    [INLONG-6568][Manager] Fix the problem that the status of the deleted 
source was incorrectly modified (#6569)
---
 .../src/main/resources/mappers/StreamSourceEntityMapper.xml            | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
 
b/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
index 97ef663fe..05fa7fbe7 100644
--- 
a/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
+++ 
b/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
@@ -379,7 +379,8 @@
         set previous_status = status,
         status = #{nextStatus, jdbcType=INTEGER}
         <where>
-            inlong_group_id = #{groupId, jdbcType=VARCHAR}
+            is_deleted = 0
+            and inlong_group_id = #{groupId, jdbcType=VARCHAR}
             <if test="streamId != null">
                 and inlong_stream_id = #{streamId, jdbcType=VARCHAR}
             </if>

Reply via email to