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

add truncate_table retry error code

Browse Source
This commit is contained in:
obdev
2023-03-02 18:56:52 +00:00
committed by ob-robot
parent ca825173cf
commit 9447a59f54
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/engine/cmd/ob_table_executor.cpp
View File

@ -1720,7 +1720,8 @@ int ObTruncateTableExecutor::execute(ObExecContext &ctx, ObTruncateTableStmt &st
while (OB_SUCC(ret)) { while (OB_SUCC(ret)) {
if (OB_FAIL(common_rpc_proxy->truncate_table_v2(truncate_table_arg, res))) { if (OB_FAIL(common_rpc_proxy->truncate_table_v2(truncate_table_arg, res))) {
LOG_WARN("rpc proxy truncate table failed", K(ret)); LOG_WARN("rpc proxy truncate table failed", K(ret));
if ((OB_TRY_LOCK_ROW_CONFLICT == ret || OB_TIMEOUT == ret || OB_NOT_MASTER == ret || OB_RS_NOT_MASTER == ret) && ctx.get_timeout() > 0) { if ((OB_TRY_LOCK_ROW_CONFLICT == ret || OB_TIMEOUT == ret || OB_NOT_MASTER == ret
|| OB_RS_NOT_MASTER == ret || OB_RS_SHUTDOWN == ret || OB_TENANT_NOT_IN_SERVER == ret) && ctx.get_timeout() > 0) {
ob_usleep(1 * 1000 * 1000); ob_usleep(1 * 1000 * 1000);
// retry // retry
ret = OB_SUCCESS; ret = OB_SUCCESS;