diff --git a/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java b/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java index 977ae1bca1f5bd..6cfcff34e093bb 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java @@ -172,7 +172,7 @@ private boolean handleHbResponse(HeartbeatResponse response, boolean isReplay) { if (hbResponse.getStatus() != HbStatus.OK) { // invalid all connections cached in ClientPool ClientPool.backendPool.clearPool(new TNetworkAddress(be.getHost(), be.getBePort())); - if (!isReplay) { + if (!isReplay && System.currentTimeMillis() - be.getLastUpdateMs() > 60 * 1000L) { Env.getCurrentEnv().getGlobalTransactionMgr() .abortTxnWhenCoordinateBeDown(be.getHost(), 100); }