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 4ed7a95fb38 branch-3.0: [fix](cloud) Not log npe in
unprotectUpdateCloudReplica when partitio… #55165 (#55220)
4ed7a95fb38 is described below
commit 4ed7a95fb38c4107d69580cf3b93f287f7a0023c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Aug 24 22:26:26 2025 +0800
branch-3.0: [fix](cloud) Not log npe in unprotectUpdateCloudReplica when
partitio… #55165 (#55220)
Cherry-picked from #55165
Co-authored-by: deardeng <[email protected]>
---
.../java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
index ca1052afeeb..ad7596c18fa 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
@@ -1016,6 +1016,10 @@ public class CloudInternalCatalog extends
InternalCatalog {
private void unprotectUpdateCloudReplica(OlapTable olapTable,
UpdateCloudReplicaInfo info) {
LOG.debug("replay update a cloud replica {}", info);
Partition partition = olapTable.getPartition(info.getPartitionId());
+ if (partition == null) {
+ LOG.warn("replay update cloud replica, unknown partition {}, may
be dropped", info.toString());
+ return;
+ }
MaterializedIndex materializedIndex =
partition.getIndex(info.getIndexId());
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
