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

standby_cluster - MA - create tenant failed, all ddl operation cannot execute

Browse Source
This commit is contained in:
zbf0
2021-08-26 21:13:23 +08:00
committed by wangzelin.wzl
parent 06c52b5070
commit ca421cf838
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/share/ob_leader_election_waiter.cpp
View File

@ -37,13 +37,12 @@ int ObLeaderElectionWaiter::wait(const uint64_t table_id, const int64_t partitio
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
const int64_t start_time = ObTimeUtility::current_time(); const int64_t start_time = ObTimeUtility::current_time();
const int64_t abs_timeout = start_time + timeout;
ObAddr leader; ObAddr leader;
if (!ObIPartitionTable::is_valid_key(table_id, partition_id) || timeout <= 0) { if (!ObIPartitionTable::is_valid_key(table_id, partition_id) || timeout <= 0) {
ret = OB_INVALID_ARGUMENT; ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret), KT(table_id), K(partition_id), K(timeout)); LOG_WARN("invalid argument", K(ret), KT(table_id), K(partition_id), K(timeout));
} else if (OB_FAIL(wait(table_id, partition_id, abs_timeout, leader))) { } else if (OB_FAIL(wait(table_id, partition_id, timeout, leader))) {
LOG_WARN("wait failed", KT(table_id), K(partition_id), K(abs_timeout), K(ret)); LOG_WARN("wait failed", KT(table_id), K(partition_id), K(timeout), K(ret));
} }
LOG_WAIT_RESULT(start_time, KT(table_id), K(partition_id), K(timeout)); LOG_WAIT_RESULT(start_time, KT(table_id), K(partition_id), K(timeout));
return ret; return ret;