This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new ad2890d0295 branch-3.1: [fix](grace-stop) remove heartbeat
condition#58019 (#58047)
ad2890d0295 is described below
commit ad2890d0295cedb6fc36008ad79f707d41ddf46b
Author: Mingyu Chen (Rayner) <[email protected]>
AuthorDate: Wed Nov 19 14:32:28 2025 +0800
branch-3.1: [fix](grace-stop) remove heartbeat condition#58019 (#58047)
bp #58019
---
.../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 89de4f8b49d..808b978d0a0 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
@@ -415,11 +415,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]
