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

[CP] [OBCDC] Fix obcdc use incorrect sql_proxy for timezone_info_getter

Browse Source
This commit is contained in:
SanmuWangZJU
2024-02-04 03:42:39 +00:00
committed by ob-robot
parent 5917742146
commit 73ec641f24
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/logservice/libobcdc/src/ob_log_instance.cpp
View File

@ -867,10 +867,19 @@ int ObLogInstance::init_components_(const uint64_t start_tstamp_ns)
INIT(tenant_mgr_, ObLogTenantMgr, enable_oracle_mode_match_case_sensitive, refresh_mode_); INIT(tenant_mgr_, ObLogTenantMgr, enable_oracle_mode_match_case_sensitive, refresh_mode_);
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (is_tenant_sync_mode()) {
if (OB_FAIL(ObCDCTimeZoneInfoGetter::get_instance().init(TCONF.timezone.str(), if (OB_FAIL(ObCDCTimeZoneInfoGetter::get_instance().init(TCONF.timezone.str(),
mysql_proxy_.get_ob_mysql_proxy(), *systable_helper_, *err_handler))) { mysql_proxy_.get_ob_mysql_proxy(), *systable_helper_, *err_handler))) {
LOG_ERROR("init timezone_info_getter failed", KR(ret)); LOG_ERROR("init timezone_info_getter failed", KR(ret));
}
} else { } else {
if (OB_FAIL(ObCDCTimeZoneInfoGetter::get_instance().init(TCONF.timezone.str(),
tenant_sql_proxy_.get_ob_mysql_proxy(), *systable_helper_, *err_handler))) {
LOG_ERROR("init timezone_info_getter failed", KR(ret));
}
}
if (OB_SUCC(ret)) {
timezone_info_getter_ = &ObCDCTimeZoneInfoGetter::get_instance(); timezone_info_getter_ = &ObCDCTimeZoneInfoGetter::get_instance();
// init interface for getting tenant timezone map // init interface for getting tenant timezone map
// get_tenant_tz_map_function is defined in ob_log_timezone_info_getter file // get_tenant_tz_map_function is defined in ob_log_timezone_info_getter file