[inlong] branch master updated: [INLONG-8127][Manager] Fix UT failed in HeartbeatManagerTest.testReportHeartbeat (#8128)

[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 593b80e2b [INLONG-8127][Manager] Fix UT failed in 
HeartbeatManagerTest.testReportHeartbeat (#8128)
593b80e2b is described below

commit 593b80e2b1c37d318bb7483168f2ceeb7e04a44b
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Tue May 30 21:30:11 2023 +0800

    [INLONG-8127][Manager] Fix UT failed in 
HeartbeatManagerTest.testReportHeartbeat (#8128)
---
 .../manager/service/core/heartbeat/HeartbeatManagerTest.java  | 11 -----------
 1 file changed, 11 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/heartbeat/HeartbeatManagerTest.java
 
b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/heartbeat/HeartbeatManagerTest.java
index 13b0034d8..b4d053576 100644
--- 
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/heartbeat/HeartbeatManagerTest.java
+++ 
b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/heartbeat/HeartbeatManagerTest.java
@@ -71,17 +71,6 @@ public class HeartbeatManagerTest extends ServiceBaseTest {
         InlongClusterNodeEntity clusterNode = 
clusterNodeMapper.selectByUniqueKey(nodeRequest);
         Assertions.assertNotNull(clusterNode);
         Assertions.assertEquals((int) clusterNode.getStatus(), 
NodeStatus.NORMAL.getStatus());
-
-        heartbeatManager.getHeartbeatCache().invalidateAll();
-        Thread.sleep(1000);
-
-        clusterNode = clusterNodeMapper.selectByUniqueKey(nodeRequest);
-        log.debug(JsonUtils.toJsonString(clusterNode));
-        Assertions.assertEquals((int) clusterNode.getStatus(), 
NodeStatus.HEARTBEAT_TIMEOUT.getStatus());
-
-        heartbeatManager.reportHeartbeat(msg);
-        clusterNode = clusterNodeMapper.selectByUniqueKey(nodeRequest);
-        Assertions.assertEquals((int) clusterNode.getStatus(), 
NodeStatus.NORMAL.getStatus());
     }
 
     private HeartbeatMsg createHeartbeatMsg() {