diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java index 8fcab41cff..fa86a9241e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java @@ -512,6 +512,10 @@ public class CatalogRecycleBin extends MasterDaemon implements Writable { RecyclePartitionInfo partitionInfo = idToPartition.remove(partitionId); idToRecycleTime.remove(partitionId); + if (partitionInfo == null) { + LOG.error("replayErasePartition: partitionInfo is null for partitionId[{}]", partitionId); + } + Partition partition = partitionInfo.getPartition(); if (!Env.isCheckpointThread()) { Env.getCurrentEnv().onErasePartition(partition);