diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java index 5cd474b450..15d07f76fc 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java @@ -903,6 +903,10 @@ public class RollupJob extends AlterJob { db.writeLock(); try { OlapTable olapTable = (OlapTable) db.getTable(tableId); + if (olapTable == null) { + LOG.warn("table {} could not be found when replay rollup job", tableId); + return; + } olapTable.setState(OlapTableState.NORMAL); } finally { db.writeUnlock();