diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java index 8187e96656..96d0f7f4e1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java @@ -397,6 +397,10 @@ public class BinlogManager { for (BinlogTombstone tombstone : binlogGcInfo.getTombstones()) { long dbId = tombstone.getDbId(); DBBinlog dbBinlog = gcDbBinlogMap.get(dbId); + if (dbBinlog == null) { + LOG.warn("dbBinlog not found. dbId: {}", dbId); + continue; + } dbBinlog.replayGc(tombstone); } }