hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[Patch] fix mini merge after migration

Browse Source
This commit is contained in:
obdev
2022-11-29 08:05:54 +00:00
committed by ob-robot
parent 041d624b4e
commit 1cdc9f04f6
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/storage/compaction/ob_partition_merge_policy.cpp
View File

@ -157,11 +157,10 @@ int ObPartitionMergePolicy::find_mini_merge_tables(
FLOG_INFO("memtable cannot mini merge now", K(ret), K(i), KPC(memtable), K(max_snapshot_version), K(memtable_handles), K(param)); FLOG_INFO("memtable cannot mini merge now", K(ret), K(i), KPC(memtable), K(max_snapshot_version), K(memtable_handles), K(param));
break; break;
} else if (memtable->get_end_scn() <= clog_checkpoint_scn) { } else if (memtable->get_end_scn() <= clog_checkpoint_scn) {
if (!tablet_id.is_special_merge_tablet()) { if (!tablet_id.is_special_merge_tablet() &&
if (static_cast<ObMemtable *>(memtable)->get_is_force_freeze() static_cast<ObMemtable *>(memtable)->get_is_force_freeze() &&
&& memtable->get_snapshot_version() > tablet.get_tablet_meta().snapshot_version_) { memtable->get_snapshot_version() > tablet.get_tablet_meta().snapshot_version_) {
contain_force_freeze_memtable = true; contain_force_freeze_memtable = true;
}
} else { } else {
LOG_DEBUG("memtable wait to release", K(param), KPC(memtable)); LOG_DEBUG("memtable wait to release", K(param), KPC(memtable));
continue; continue;