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/10 04:31:38 UTC
[inlong] branch master updated: [INLONG-5846][Manager] Fix the SQL exception to check if the consumer exists (#5847)
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 b0663fd57 [INLONG-5846][Manager] Fix the SQL exception to check if the consumer exists (#5847)
b0663fd57 is described below
commit b0663fd57d68832ef7ccfd55b6f751b966e1cf72
Author: ciscozhou <45...@users.noreply.github.com>
AuthorDate: Sat Sep 10 12:31:33 2022 +0800
[INLONG-5846][Manager] Fix the SQL exception to check if the consumer exists (#5847)
---
.../src/main/resources/mappers/InlongConsumeEntityMapper.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml b/inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml
index 16e1d9b52..435d6ca3c 100644
--- a/inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml
+++ b/inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml
@@ -123,7 +123,7 @@
<include refid="Base_Column_List"/>
from inlong_consume
where is_deleted = 0
- and inlong_group_id = #{inlongGroupId, jdbcType=VARCHAR}
+ and inlong_group_id = #{groupId, jdbcType=VARCHAR}
and topic = #{topic, jdbcType=VARCHAR}
and consumer_group = #{consumerGroup, jdbcType=VARCHAR}
limit 1