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

Add some log for 4377

Browse Source
This commit is contained in:
obdev
2023-04-13 06:32:07 +00:00
committed by ob-robot
parent dc46c532ed
commit 7b958a4535
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/storage/access/ob_multiple_merge.cpp
View File

@ -1149,6 +1149,7 @@ int ObMultipleMerge::prepare_tables_from_iterator(ObTableStoreIterator &table_it
table_iter.resume(); table_iter.resume();
int64_t memtable_cnt = 0; int64_t memtable_cnt = 0;
read_memtable_only_ = false; read_memtable_only_ = false;
bool read_released_memtable = false;
while (OB_SUCC(ret)) { while (OB_SUCC(ret)) {
ObITable *table_ptr = nullptr; ObITable *table_ptr = nullptr;
bool need_table = true; bool need_table = true;
@ -1174,6 +1175,8 @@ int ObMultipleMerge::prepare_tables_from_iterator(ObTableStoreIterator &table_it
LOG_DEBUG("cur table is empty", K(ret), KPC(table_ptr)); LOG_DEBUG("cur table is empty", K(ret), KPC(table_ptr));
continue; continue;
} else if (table_ptr->is_memtable()) { } else if (table_ptr->is_memtable()) {
read_released_memtable = read_released_memtable ||
memtable::ObMemtableFreezeState::RELEASED == (static_cast<memtable::ObMemtable*>(table_ptr))->get_freeze_state();
++memtable_cnt; ++memtable_cnt;
} }
if (OB_FAIL(tables_.push_back(table_ptr))) { if (OB_FAIL(tables_.push_back(table_ptr))) {
@ -1193,6 +1196,13 @@ int ObMultipleMerge::prepare_tables_from_iterator(ObTableStoreIterator &table_it
if (OB_SUCC(ret) && memtable_cnt == tables_.count()) { if (OB_SUCC(ret) && memtable_cnt == tables_.count()) {
read_memtable_only_ = true; read_memtable_only_ = true;
} }
#ifdef ENABLE_DEBUG_LOG
if (GCONF.enable_defensive_check() && read_released_memtable) {
for (int64_t i = 0; i < tables_.count(); ++i) {
LOG_INFO("dump read tables", KPC(tables_.at(i)));
}
}
#endif
return ret; return ret;
} }