(doris) branch master updated: [Fix](group commit) Fix Group Commit Selecting Non-Alive Backend Instances (#44577)

[gavinchou]

This is an automated email from the ASF dual-hosted git repository.

gavinchou 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 45dc1c91a0d [Fix](group commit) Fix Group Commit Selecting Non-Alive 
Backend Instances (#44577)
45dc1c91a0d is described below

commit 45dc1c91a0dba0ee5f2663167d5dee24a409bfae
Author: abmdocrt <yukang.lian2...@gmail.com>
AuthorDate: Wed Nov 27 10:57:44 2024 +0800

    [Fix](group commit) Fix Group Commit Selecting Non-Alive Backend Instances 
(#44577)
---
 .../src/main/java/org/apache/doris/load/GroupCommitManager.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java 
b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
index 60394f94365..1844ec5bf2b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
@@ -336,7 +336,7 @@ public class GroupCommitManager {
                     return null;
                 }
                 Backend backend = 
Env.getCurrentSystemInfo().getBackend(backendId);
-                if (backend != null && backend.isActive() && 
!backend.isDecommissioned()) {
+                if (backend != null && backend.isAlive() && 
!backend.isDecommissioned()) {
                     return backend.getId();
                 } else {
                     tableToBeMap.remove(encode(cluster, tableId));
@@ -353,7 +353,7 @@ public class GroupCommitManager {
         OlapTable table = (OlapTable) 
Env.getCurrentEnv().getInternalCatalog().getTableByTableId(tableId);
         Collections.shuffle(backends);
         for (Backend backend : backends) {
-            if (backend.isActive() && !backend.isDecommissioned()) {
+            if (backend.isAlive() && !backend.isDecommissioned()) {
                 tableToBeMap.put(encode(cluster, tableId), backend.getId());
                 tableToPressureMap.put(tableId,
                         new 
SlidingWindowCounter(table.getGroupCommitIntervalMs() / 1000 + 1));


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org