Fix rpc post error of clean sequence cache
This commit is contained in:
@ -159,10 +159,16 @@ int ObSequenceSqlService::clean_sequence_cache(uint64_t tenant_id, uint64_t sequ
|
|||||||
.by(tenant_id)
|
.by(tenant_id)
|
||||||
.timeout(timeout)
|
.timeout(timeout)
|
||||||
.clean_sequence_cache(sequence_id))) {
|
.clean_sequence_cache(sequence_id))) {
|
||||||
|
if (is_timeout_err(ret) || is_server_down_error(ret)) {
|
||||||
|
LOG_WARN("rpc call time out, ignore the error", "server", server_list.at(i),
|
||||||
|
K(tenant_id), K(sequence_id), K(ret));
|
||||||
|
ret = OB_SUCCESS;
|
||||||
|
} else {
|
||||||
LOG_WARN("clean sequnece cache failed", K(ret), K(sequence_id), K(server_list.at(i)));
|
LOG_WARN("clean sequnece cache failed", K(ret), K(sequence_id), K(server_list.at(i)));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user