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 532e3a9a8 [INLONG-6992][Manager] Fix the problem of agent is always in
the status of TO_BE_ISSUED_DELETE (#6993)
532e3a9a8 is described below
commit 532e3a9a8473cbdb1c879de3336df58a1ec9abdc
Author: fuweng11 <[email protected]>
AuthorDate: Tue Dec 20 20:05:45 2022 +0800
[INLONG-6992][Manager] Fix the problem of agent is always in the status of
TO_BE_ISSUED_DELETE (#6993)
---
.../manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml | 2 +-
1 file changed, 1 insertion(+), 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 e19a05edc..804d47c03 100644
---
a/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
+++
b/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
@@ -229,7 +229,7 @@
<include refid="Base_Column_List"/>
from stream_source
<where>
- inlong_cluster_name = #{clusterName, jdbcType=VARCHAR}
+ (inlong_cluster_name = #{clusterName, jdbcType=VARCHAR} or
inlong_cluster_name is NULL)
and agent_ip = #{agentIp, jdbcType=VARCHAR}
and `status` in
<foreach item="item" index="index" collection="statusList"
open="(" close=")" separator=",">
