[inlong] branch master updated: [INLONG-6992][Manager] Fix the problem of agent is always in the status of TO_BE_ISSUED_DELETE (#6993)

[dockerzhang]

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 <76141879+fuwen...@users.noreply.github.com>
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=",">