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

Fix autoinc arg ls id not refreshed

Browse Source
This commit is contained in:
Hongqin-Li
2023-08-15 11:11:09 +00:00
committed by ob-robot
parent 7f4ebd09f5
commit 5d6f34fc35
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/share/ob_tablet_autoincrement_service.cpp
View File

@ -166,14 +166,14 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam &param,
if (OB_FAIL(THIS_WORKER.check_status())) { // overwrite ret if (OB_FAIL(THIS_WORKER.check_status())) { // overwrite ret
LOG_WARN("failed to check status", K(ret)); LOG_WARN("failed to check status", K(ret));
} else if (need_refresh_leader) { } else if (need_refresh_leader) {
if (OB_FAIL(location_service->get(param.tenant_id_, tablet_id, INT64_MAX/*expire_renew_time*/, is_cache_hit, ls_id))) { if (OB_FAIL(location_service->get(param.tenant_id_, tablet_id, INT64_MAX/*expire_renew_time*/, is_cache_hit, arg.ls_id_))) {
LOG_WARN("fail to get log stream id", K(ret), K(ret), K(tablet_id)); LOG_WARN("fail to get log stream id", K(ret), K(ret), K(tablet_id));
} else if (OB_FAIL(location_service->get_leader(GCONF.cluster_id, } else if (OB_FAIL(location_service->get_leader(GCONF.cluster_id,
param.tenant_id_, param.tenant_id_,
ls_id, arg.ls_id_,
true/*force_renew*/, true/*force_renew*/,
leader_addr))) { leader_addr))) {
LOG_WARN("force get leader failed", K(ret), K(ret), K(ls_id)); LOG_WARN("force get leader failed", K(ret), K(ret), K(arg.ls_id_));
} }
} }
} }