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 <= 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>