From 5bbe9f7b4060f0893538cb3c0e01bdba254f2c70 Mon Sep 17 00:00:00 2001 From: Jack Drogon Date: Wed, 28 Feb 2024 11:33:11 +0800 Subject: [PATCH] Fix replay binlog gc when not found db binlog (#31463) Signed-off-by: Jack Drogon --- .../src/main/java/org/apache/doris/binlog/BinlogManager.java | 4 ++++ 1 file changed, 4 insertions(+) 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); } }