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

fix get data size fail causing index fail

Browse Source
This commit is contained in:
YoungYang0820
2022-04-14 11:19:59 +08:00
committed by LINxiansheng
parent d9916dc4dd
commit 7052c033e1
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/storage/ob_build_index_scheduler.cpp
View File

@ -980,6 +980,7 @@ int ObBuildIndexScheduleTask::send_copy_replica_rpc()
} }
ret = OB_EAGAIN; ret = OB_EAGAIN;
} else { } else {
int tmp_ret = OB_SUCCESS;
obrpc::ObServerCopyLocalIndexSSTableArg arg; obrpc::ObServerCopyLocalIndexSSTableArg arg;
ObAddr rs_addr; ObAddr rs_addr;
ObSchemaGetterGuard schema_guard; ObSchemaGetterGuard schema_guard;
@ -990,12 +991,14 @@ int ObBuildIndexScheduleTask::send_copy_replica_rpc()
arg.pkey_ = pkey_; arg.pkey_ = pkey_;
arg.index_table_id_ = index_id_; arg.index_table_id_ = index_id_;
arg.cluster_id_ = GCONF.cluster_id; arg.cluster_id_ = GCONF.cluster_id;
if (OB_SUCCESS != (tmp_ret = get_data_size(arg.data_size_))) {
arg.data_size_ = 0;
STORAGE_LOG(INFO, "fail to get data size, will use data table size to estimate", K(tmp_ret));
}
if (arg.data_src_ == arg.dst_) { if (arg.data_src_ == arg.dst_) {
// if the source and destination are the same, it means that this replica builds the index sstable itself, // if the source and destination are the same, it means that this replica builds the index sstable itself,
// just retry the scheduling process will get the right way to next state // just retry the scheduling process will get the right way to next state
ret = OB_EAGAIN; ret = OB_EAGAIN;
} else if (OB_FAIL(get_data_size(arg.data_size_))) {
STORAGE_LOG(WARN, "fail to get data size", K(ret));
} else if (OB_FAIL(ObMultiVersionSchemaService::get_instance().get_tenant_full_schema_guard( } else if (OB_FAIL(ObMultiVersionSchemaService::get_instance().get_tenant_full_schema_guard(
extract_tenant_id(index_id_), schema_guard))) { extract_tenant_id(index_id_), schema_guard))) {
STORAGE_LOG(WARN, "fail to get schema guard", K(ret), K(schema_version_)); STORAGE_LOG(WARN, "fail to get schema guard", K(ret), K(schema_version_));