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

[BUG] clear record when data not changed

Browse Source
This commit is contained in:
handora 2021-08-17 14:02:38 +08:00 committed by wangzelin.wzl
parent 8dab36fe5d
commit 0c581542a7
1 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/storage/ob_partition_group.cpp
View File

@ -3875,22 +3875,25 @@ int ObPartitionGroup::freeze_log_and_data_v2_(const bool emergency, const bool f
}
} else if (!changed) {
// skip
} else if (OB_FAIL(submit_freeze_and_effect_memstore_(
is_leader, emergency, *frozen_memtable, effected, snapshot_version))) {
STORAGE_LOG(WARN, "submit freeze and prepare memstore", K(ret), K(pkey_), K(*frozen_memtable));
} else if (effected) {
if (OB_FAIL(pg_storage_.get_active_memtable(new_handle))) {
STORAGE_LOG(WARN, "fail to get new active memtable", K(ret), K(pkey_));
} else if (OB_FAIL(freeze_record_.submit_new_active_memtable(new_handle))) {
// Submit a new memtable. Allow async_freeze threads to scan and synchronize log.
STORAGE_LOG(ERROR, "fail to submit freeze record", K(ret), K(pkey_));
} else {
STORAGE_LOG(INFO, "submit_new_active_memtable success", K(ret), K(pkey_));
} else {
if (OB_FAIL(
submit_freeze_and_effect_memstore_(is_leader, emergency, *frozen_memtable, effected, snapshot_version))) {
STORAGE_LOG(WARN, "submit freeze and prepare memstore", K(ret), K(pkey_), K(*frozen_memtable));
} else if (effected) {
if (OB_FAIL(pg_storage_.get_active_memtable(new_handle))) {
STORAGE_LOG(WARN, "fail to get new active memtable", K(ret), K(pkey_));
} else if (OB_FAIL(freeze_record_.submit_new_active_memtable(new_handle))) {
// Submit a new memtable. Allow async_freeze threads to scan and synchronize log.
STORAGE_LOG(ERROR, "fail to submit freeze record", K(ret), K(pkey_));
} else {
STORAGE_LOG(INFO, "submit_new_active_memtable success", K(ret), K(pkey_));
}
}
}
if (OB_FAIL(ret) || !effected) {
freeze_record_.clear();
if (OB_FAIL(ret) || !effected) {
TRANS_LOG(INFO, "clear the record when failed", K(*this));
freeze_record_.clear();
}
}
return ret;