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

fix master failed cases

Browse Source
This commit is contained in:
wangt1xiuyi
2023-11-03 09:09:25 +00:00
committed by ob-robot
parent a2a3acd52a
commit 718887095b
3 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/sql/ob_sql_utils.cpp
View File

@ -2853,8 +2853,13 @@ int ObSQLUtils::choose_best_partition_replica_addr(const ObAddr &local_addr,
candi_locality))) {
LOG_WARN("fail to get server locality", K(all_server_arr), K(candi_addr), K(ret));
} else if (OB_UNLIKELY(!candi_locality.is_init())) {
// not find
// do nothing
//maybe the locality cache hasn't been flushed yet, we just trust it.
if (local_addr == candi_addr) {
selected_addr = candi_addr;
need_continue = false;
} else if (OB_FAIL(other_region_addr.push_back(candi_addr))) {
LOG_WARN("failed to push back other region candidate address", K(ret));
} else {/*do nothing*/}
} else if (!candi_locality.is_active()
|| ObServerStatus::OB_SERVER_ACTIVE != candi_locality.get_server_status()
|| 0 == candi_locality.get_start_service_time()