You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/03/17 10:51:25 UTC
[incubator-inlong] branch master updated: [INLONG-3190][Manager] Fix SQL error in the select source list (#3191)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new b62e1b3 [INLONG-3190][Manager] Fix SQL error in the select source list (#3191)
b62e1b3 is described below
commit b62e1b312d0f284df3f365601f40b652282fa6ef
Author: pacino <ge...@gmail.com>
AuthorDate: Thu Mar 17 18:51:20 2022 +0800
[INLONG-3190][Manager] Fix SQL error in the select source list (#3191)
---
.../src/main/resources/mappers/StreamSourceEntityMapper.xml | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
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 874f919..18d1492 100644
--- a/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
+++ b/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
@@ -45,7 +45,8 @@
<result column="modify_time" jdbcType="TIMESTAMP" property="modifyTime"/>
</resultMap>
<sql id="Base_Column_List">
- id, inlong_group_id, inlong_stream_id, source_type, source_name, agent_ip, uuid,
+ id
+ , inlong_group_id, inlong_stream_id, source_type, source_name, agent_ip, uuid,
server_id, server_name, cluster_id, cluster_name, snapshot, report_time, ext_params,
status, previous_status, is_deleted, creator, modifier, create_time, modify_time
</sql>
@@ -262,7 +263,7 @@
and inlong_stream_id = #{streamId, jdbcType=VARCHAR}
</if>
<if test="sourceName != null and sourceName != ''">
- and source_name = #{sourceName, jdbcType=VARCHAR},
+ and source_name = #{sourceName, jdbcType=VARCHAR}
</if>
for update
</where>