database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](report handler) fix report handler lock leak (#25853)

Browse Source
This commit is contained in:
yujun
2023-10-24 21:43:55 +08:00
committed by GitHub
parent 40e430ca55
commit b82136bdb9
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java
View File

@ -590,6 +590,7 @@ public class ReportHandler extends Daemon {
private static void sync(Map<Long, TTablet> backendTablets, ListMultimap<Long, Long> 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) {