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/11/17 10:36:12 UTC
[inlong] branch master updated: [INLONG-6568][Manager] Fix the problem that the status of the deleted source was incorrectly modified (#6569)
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 <76...@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>