[INLONG-10270][Manager] Data source tasks allow for multiple IPs (apa…

…che#10271)
XiaoYou201 · May 27, 2024 · ca3fd42 · ca3fd42
1 parent ca4bc8d
commit ca3fd42
Showing 1 changed file with 2 additions and 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
@@ -293,8 +293,8 @@
         <include refid="Base_Column_List"/>
         from stream_source
         <where>
-            (inlong_cluster_name = #{clusterName, jdbcType=VARCHAR} or inlong_cluster_name is NULL)
-            and agent_ip = #{agentIp, jdbcType=VARCHAR}
+            (inlong_cluster_name = #{clusterName, jdbcType=VARCHAR})
+            and (find_in_set( #{agentIp, jdbcType=VARCHAR}, agent_ip) or agent_ip ='All')
             and `status` in
             <foreach item="item" index="index" collection="statusList" open="(" close=")" separator=",">
                 #{item}