From 88d03b5f1d6f85f8eb6182ea0ec0b2104f1ef026 Mon Sep 17 00:00:00 2001 From: yujun777 Date: Mon, 22 Jul 2024 14:49:28 +0800 Subject: [PATCH 1/2] decommission replica not load data if it miss version --- fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java index 3266d0eeb660bd..bb2d6b52730b75 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java @@ -242,7 +242,9 @@ private Multimap getNormalReplicaBackendPathMapImpl(String beEndpoin ReplicaState state = replica.getState(); if (state.canLoad() - || (state == ReplicaState.DECOMMISSION && replica.getPostWatermarkTxnId() < 0)) { + || (state == ReplicaState.DECOMMISSION + && replica.getPostWatermarkTxnId() < 0 + && replica.getLastFailedVersion() > 0)) { map.put(backendId, replica.getPathHash()); } } From fdb446422972f30b0a75036348a5d9dd57a985ee Mon Sep 17 00:00:00 2001 From: yujun777 Date: Mon, 22 Jul 2024 15:02:39 +0800 Subject: [PATCH 2/2] update --- fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java index bb2d6b52730b75..c32b2bcbfa9e3e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java @@ -244,7 +244,7 @@ private Multimap getNormalReplicaBackendPathMapImpl(String beEndpoin if (state.canLoad() || (state == ReplicaState.DECOMMISSION && replica.getPostWatermarkTxnId() < 0 - && replica.getLastFailedVersion() > 0)) { + && replica.getLastFailedVersion() < 0)) { map.put(backendId, replica.getPathHash()); } }