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 <[email protected]>
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