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 ca3fd42542 [INLONG-10270][Manager] Data source tasks allow for
multiple IPs (#10271)
ca3fd42542 is described below
commit ca3fd42542ce01280b43edfe680285f21ce6088b
Author: fuweng11 <[email protected]>
AuthorDate: Mon May 27 11:10:40 2024 +0800
[INLONG-10270][Manager] Data source tasks allow for multiple IPs (#10271)
---
.../src/main/resources/mappers/StreamSourceEntityMapper.xml | 4 ++--
1 file changed, 2 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 9008bcb7a1..732a5cfd56 100644
---
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}
