fix truncate_table retry error code and fix farm case
This commit is contained in:
@ -1650,6 +1650,7 @@ typedef enum ObItemType
|
||||
T_RANDOM,
|
||||
T_TABLEGROUP_ID,
|
||||
T_TABLEGROUP_BINDING,
|
||||
T_TABLEGROUP_SHARDING,
|
||||
T_MAX_USED_PART_ID,
|
||||
T_TENANT_ID,
|
||||
|
||||
|
||||
@ -1720,7 +1720,7 @@ int ObTruncateTableExecutor::execute(ObExecContext &ctx, ObTruncateTableStmt &st
|
||||
while (OB_SUCC(ret)) {
|
||||
if (OB_FAIL(common_rpc_proxy->truncate_table_v2(truncate_table_arg, res))) {
|
||||
LOG_WARN("rpc proxy truncate table failed", K(ret));
|
||||
if ((OB_TRY_LOCK_ROW_CONFLICT == ret || OB_TIMEOUT == ret) && ctx.get_timeout() > 0) {
|
||||
if ((OB_TRY_LOCK_ROW_CONFLICT == ret || OB_TIMEOUT == ret || OB_NOT_MASTER == ret || OB_RS_NOT_MASTER == ret) && ctx.get_timeout() > 0) {
|
||||
ob_usleep(1 * 1000 * 1000);
|
||||
// retry
|
||||
ret = OB_SUCCESS;
|
||||
|
||||
Reference in New Issue
Block a user