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 c707d8d031 [INLONG-8529][Manager] Update stream source to heartbeat 
timeout when evit cluster node (#8530)
c707d8d031 is described below

commit c707d8d03146754e6e3ba56dcc97c1932e6b39da
Author: kipshi <[email protected]>
AuthorDate: Fri Jul 21 09:35:49 2023 +0800

    [INLONG-8529][Manager] Update stream source to heartbeat timeout when evit 
cluster node (#8530)
    
    Co-authored-by: kipshi <[email protected]>
---
 .../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 700d740f2c..7ae871cad4 100644
--- 
a/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
+++ 
b/inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml
@@ -548,7 +548,7 @@
         <where>
             is_deleted = 0
             and modify_time &lt;= DATE_ADD(NOW(), INTERVAL -#{beforeSeconds, 
jdbcType=INTEGER} SECOND)
-            and status in (200, 201, 202, 203, 204, 205, 206, 207, 208)
+            and status not in (101, 102, 104, 105, 110)
         </where>
     </update>
 

Reply via email to