diff --git a/fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java b/fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java index efca6c7f95..f004cb0d7e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java @@ -590,6 +590,7 @@ public class ReportHandler extends Daemon { private static void sync(Map backendTablets, ListMultimap tabletSyncMap, long backendId, long backendReportVersion) { TabletInvertedIndex invertedIndex = Env.getCurrentInvertedIndex(); + OUTER: for (Long dbId : tabletSyncMap.keySet()) { Database db = Env.getCurrentInternalCatalog().getDbNullable(dbId); if (db == null) { @@ -612,11 +613,11 @@ public class ReportHandler extends Daemon { continue; } - if (backendReportVersion < Env.getCurrentSystemInfo().getBackendReportVersion(backendId)) { - break; - } - try { + if (backendReportVersion < Env.getCurrentSystemInfo().getBackendReportVersion(backendId)) { + break OUTER; + } + long partitionId = tabletMeta.getPartitionId(); Partition partition = olapTable.getPartition(partitionId); if (partition == null) {