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

fix ret code in get_read_tables

Browse Source
This commit is contained in:
obdev
2022-11-17 02:05:40 +00:00
committed by wangzelin.wzl
parent c13e46137f
commit 2171913b09
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/storage/tablet/ob_tablet_table_store.cpp
View File

@ -518,9 +518,16 @@ int ObTabletTableStore::calculate_read_tables(
LOG_WARN("exist base table, but no read table found for specific version", K(ret), K(snapshot_version), K(iterator), K(PRINT_TS(*this))); LOG_WARN("exist base table, but no read table found for specific version", K(ret), K(snapshot_version), K(iterator), K(PRINT_TS(*this)));
} }
} else { // not find base table } else { // not find base table
if (!allow_no_ready_read || !major_tables_.empty()) { if (!allow_no_ready_read) {
ret = OB_REPLICA_NOT_READABLE; if (major_tables_.empty()) {
LOG_WARN("no base table, not allow no ready read, no table found for specific version", K(ret), K(snapshot_version), K(PRINT_TS(*this))); ret = OB_REPLICA_NOT_READABLE;
LOG_WARN("no base table, not allow no ready read, tablet is not readable",
K(ret), K(snapshot_version), K(allow_no_ready_read), K(PRINT_TS(*this)));
} else {
ret = OB_SNAPSHOT_DISCARDED;
LOG_WARN("no base table found for specific version",
K(ret), K(snapshot_version), K(allow_no_ready_read), K(PRINT_TS(*this)));
}
} else if (!minor_tables_.empty() && OB_FAIL(iterator.add_tables(minor_tables_.array_, minor_tables_.count_))) { } else if (!minor_tables_.empty() && OB_FAIL(iterator.add_tables(minor_tables_.array_, minor_tables_.count_))) {
LOG_WARN("failed to add all minor tables to iterator", K(ret)); LOG_WARN("failed to add all minor tables to iterator", K(ret));
} else { } else {