This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 915b33769c4 [fix](grace-stop) remove heartbeat condition (#58019)
915b33769c4 is described below
commit 915b33769c40891edafc454031973bb30dec10d8
Author: Mingyu Chen (Rayner) <[email protected]>
AuthorDate: Sat Nov 15 11:56:51 2025 +0800
[fix](grace-stop) remove heartbeat condition (#58019)
Followup #56601
---
.../src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
index df59b3d67cc..635aa5e6f4c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
@@ -419,11 +419,7 @@ public class CloudReplica extends Replica {
List<Backend> availableBes = new ArrayList<>();
List<Backend> decommissionAvailBes = new ArrayList<>();
for (Backend be : clusterBes) {
- long lastUpdateMs = be.getLastUpdateMs();
- long missTimeMs = Math.abs(lastUpdateMs -
System.currentTimeMillis());
- // be core or restart must in heartbeat_interval_second
- if ((be.isQueryAvailable() || missTimeMs <=
Config.heartbeat_interval_second * 1000L)
- && !be.isSmoothUpgradeSrc()) {
+ if (be.isQueryAvailable() && !be.isSmoothUpgradeSrc()) {
if (be.isDecommissioned()) {
decommissionAvailBes.add(be);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
