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

[Bugfix] SQL doesn't retry while schema is not refreshed

Browse Source
This commit is contained in:
obdev
2022-11-04 07:07:56 +00:00
committed by wangzelin.wzl
parent d28594a82f
commit 8468987992
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/share/schema/ob_multi_version_schema_service.cpp
View File

@ -3514,12 +3514,18 @@ bool ObMultiVersionSchemaService::is_schema_error_need_retry(
const uint64_t tenant_id) const uint64_t tenant_id)
{ {
bool bret = false; bool bret = false;
if (!is_sys_full_schema()) {
// observer may be not start service, do not retry
} else if (is_tenant_full_schema(tenant_id)) {
// refresh schema success once, do not retry
} else {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
bool schema_not_full = false;
int64_t schema_version = OB_INVALID_VERSION;
if (OB_FAIL(refresh_full_schema_map_.get_refactored(OB_SYS_TENANT_ID, schema_not_full))) {
// skip
} else if (schema_not_full) {
// observer may be not start service, do not retry
} else if (OB_FAIL(refresh_full_schema_map_.get_refactored(tenant_id, schema_not_full))) {
// skip
} else if (!schema_not_full) {
// tenant's schema is full, do not retry
} else {
ObSchemaGetterGuard tmp_guard; ObSchemaGetterGuard tmp_guard;
const ObSimpleTenantSchema *tenant_schema = NULL; const ObSimpleTenantSchema *tenant_schema = NULL;
if (OB_ISNULL(guard)) { if (OB_ISNULL(guard)) {
@ -3540,7 +3546,7 @@ bool ObMultiVersionSchemaService::is_schema_error_need_retry(
// 2. restoring // 2. restoring
// 3. dropping // 3. dropping
} else { } else {
// normal // observer restarts
bret = true; bret = true;
} }
} }