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

[CP] fix drop_table bug in data_dict refresh mode

Browse Source
This commit is contained in:
fkuner
2024-04-01 04:15:51 +00:00
committed by ob-robot
parent 09dee5c2fb
commit e8a06e8f38
3 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/logservice/libobcdc/src/ob_log_part_mgr.cpp
View File

@ -2268,8 +2268,8 @@ int ObLogPartMgr::get_schema_info_of_table_id_(const uint64_t table_id,
if (OB_TIMEOUT != ret) {
LOG_ERROR("get schema_guard and table_schema failed", KR(ret), K(table_id), K(schema_version));
}
} else if (inner_get_table_info_of_table_schema_(schema_guard, table_schema, tenant_name,
database_name, table_name, database_id, is_user_table, timeout)) {
} else if (OB_FAIL(inner_get_table_info_of_table_schema_(schema_guard, table_schema, tenant_name,
database_name, table_name, database_id, is_user_table, timeout))) {
if (OB_TIMEOUT != ret) {
LOG_ERROR("inner get table info failed", KR(ret), KPC(table_schema));
}
@ -2286,8 +2286,11 @@ int ObLogPartMgr::get_schema_info_of_table_id_(const uint64_t table_id,
} else if (OB_ISNULL(tenant_info = dict_tenant_info_guard.get_tenant_info())) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("tenant_info is nullptr", KR(ret), K_(tenant_id));
} else if (inner_get_table_info_of_table_meta_(tenant_info, table_meta, tenant_name,
database_name, table_name, database_id, is_user_table)) {
} else if (OB_FAIL(tenant_info->get_table_meta(table_id, table_meta))) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("get table_meta failed", KR(ret), K_(tenant_id), K(table_id));
} else if (OB_FAIL(inner_get_table_info_of_table_meta_(tenant_info, table_meta, tenant_name,
database_name, table_name, database_id, is_user_table))) {
LOG_ERROR("inner get table info failed", KR(ret), KPC(tenant_info));
} else {
// succ

1
src/logservice/libobcdc/src/ob_log_part_mgr.h
View File

@ -582,6 +582,7 @@ private:
uint64_t &database_id,
bool &is_user_table,
const int64_t timeout);
// For optimization, table_match is not required in drop_table scenario
int get_schema_info_of_table_id_(const uint64_t table_id,
const int64_t schema_version,
const char *&tenant_name,

2
src/logservice/libobcdc/src/ob_log_sequencer1.cpp
View File

@ -1391,7 +1391,7 @@ int ObLogSequencer::need_acquire_new_schema_(const PartTransTask &task, bool &ne
}
}
}
LOG_INFO("ddl task schema info", KR(ret), K(need_new_schema), K(task));
LOG_DEBUG("ddl task needs schema info", KR(ret), K(task), K(need_new_schema));
return ret;
}