Skip to content

Commit 915b337

Browse files
authored
[fix](grace-stop) remove heartbeat condition (#58019)
Followup #56601
1 parent c75467c commit 915b337

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -419,11 +419,7 @@ public long hashReplicaToBe(String clusterId, boolean isBackGround) throws Compu
419419
List<Backend> availableBes = new ArrayList<>();
420420
List<Backend> decommissionAvailBes = new ArrayList<>();
421421
for (Backend be : clusterBes) {
422-
long lastUpdateMs = be.getLastUpdateMs();
423-
long missTimeMs = Math.abs(lastUpdateMs - System.currentTimeMillis());
424-
// be core or restart must in heartbeat_interval_second
425-
if ((be.isQueryAvailable() || missTimeMs <= Config.heartbeat_interval_second * 1000L)
426-
&& !be.isSmoothUpgradeSrc()) {
422+
if (be.isQueryAvailable() && !be.isSmoothUpgradeSrc()) {
427423
if (be.isDecommissioned()) {
428424
decommissionAvailBes.add(be);
429425
} else {

0 commit comments

Comments
 (0)