This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a commit to branch cir-17116
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/cir-17116 by this push:
new b98a9754cf8 skip null unprotectUpdateReplica (#53917)
b98a9754cf8 is described below
commit b98a9754cf8d50875cabe84bbe685306efc8d6d6
Author: deardeng <[email protected]>
AuthorDate: Fri Jul 25 19:29:51 2025 +0800
skip null unprotectUpdateReplica (#53917)
---
.../src/main/java/org/apache/doris/datasource/InternalCatalog.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 8ca76357db6..d8b6b948b8b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -1086,6 +1086,10 @@ public class InternalCatalog implements
CatalogIf<Database> {
MaterializedIndex materializedIndex =
partition.getIndex(info.getIndexId());
Tablet tablet = materializedIndex.getTablet(info.getTabletId());
Replica replica = tablet.getReplicaById(info.getReplicaId());
+ if (replica == null) {
+ LOG.warn("skip table {}, unprotectUpdateReplica {}",
olapTable.getName(), info);
+ return;
+ }
Preconditions.checkNotNull(replica, info);
replica.updateVersionWithFailed(info.getVersion(),
info.getLastFailedVersion(),
info.getLastSuccessVersion());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
