This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 57483092d9d branch-3.0: [Fix](group commit) Fix Group Commit Selecting
Non-Alive Backend Instances #44577 (#44659)
57483092d9d is described below
commit 57483092d9d98c4a125365bcf3fa979501ef98ee
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Nov 28 13:46:04 2024 +0800
branch-3.0: [Fix](group commit) Fix Group Commit Selecting Non-Alive
Backend Instances #44577 (#44659)
Cherry-picked from #44577
Co-authored-by: abmdocrt <yukang.lian2...@gmail.com>
---
.../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 3b108ed638a..72a97e4fc69 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
@@ -332,7 +332,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));
@@ -349,7 +349,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
