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

[CP] add refresh schema_status

Browse Source
This commit is contained in:
maosy
2024-04-29 04:53:40 +00:00
committed by ob-robot
parent 908d9f298c
commit 4d22af1c07
3 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/observer/ob_lease_state_mgr.cpp
View File

@ -359,6 +359,7 @@ int ObLeaseStateMgr::do_renew_lease()
ObLeaseResponse lease_response;
ObAddr rs_addr;
NG_TRACE(do_renew_lease_begin);
DEBUG_SYNC(BEFORE_SEND_HB);
if (!inited_) {
ret = OB_NOT_INIT;
LOG_WARN("not init", K(ret));

10
src/rootserver/ob_standby_schema_refresh_trigger.cpp
View File

@ -120,6 +120,14 @@ int ObStandbySchemaRefreshTrigger::submit_tenant_refresh_schema_task_()
LOG_WARN("schema_status_proxy is null", KR(ret));
} else if (OB_FAIL(schema_status_proxy->get_refresh_schema_status(tenant_id_, schema_status))) {
LOG_WARN("fail to get schema status", KR(ret), K(tenant_id_));
} else if (common::OB_INVALID_TIMESTAMP != schema_status.snapshot_timestamp_) {
//for fix bugfic:56142375
//schema_status in memory maybe not valid, try to load from table
if (OB_FAIL(schema_status_proxy->load_refresh_schema_status(tenant_id_, schema_status))) {
LOG_WARN("failed to load refresh schema status", KR(ret), K(tenant_id_));
}
}
if (OB_FAIL(ret)) {
} else if (common::OB_INVALID_TIMESTAMP == schema_status.snapshot_timestamp_) {
int64_t version_in_inner_table = OB_INVALID_VERSION;
int64_t local_schema_version = OB_INVALID_VERSION;
@ -138,6 +146,8 @@ int ObStandbySchemaRefreshTrigger::submit_tenant_refresh_schema_task_()
} else if (OB_FAIL(GCTX.ob_service_->submit_async_refresh_schema_task(tenant_id_, version_in_inner_table))) {
LOG_WARN("failed to submit_async_refresh_schema_task", KR(ret), K_(tenant_id));
}
} else if (REACH_TENANT_TIME_INTERVAL(1 * 1000 * 1000)) {
LOG_INFO("standby tenant can not refresh schema", K(schema_status));
}
}
return ret;

1
src/share/ob_debug_sync_point.h
View File

@ -250,6 +250,7 @@ class ObString;
ACT(BEFROE_LOG_ARCHIVE_SCHEDULE_SUSPENDING,)\
ACT(BEFROE_LOG_ARCHIVE_SCHEDULE_STOPPING,)\
ACT(AFTER_FREEZE_BEFORE_MINI_MERGE,)\
ACT(BEFORE_SEND_HB,)\
ACT(HUNG_HEARTBEAT_CHECK,)\
ACT(BLOCK_WEAK_READ_TIMESTAMP,)\
ACT(REPLAY_REDO_LOG,)\