[CP] block failed server in ObRemoteTaskExecutor

2023-03-27 07:44:54 +00:00
parent ee5469eeb0
commit 99dc75044c
1 changed files with 1 additions and 1 deletions
--- a/src/sql/executor/ob_remote_task_executor.cpp
+++ b/src/sql/executor/ob_remote_task_executor.cpp
@ -78,7 +78,7 @@ int ObRemoteTaskExecutor::execute(ObExecContext &query_ctx, ObJob *job, ObTaskIn
        bool skip_failed_tasks = false;
        int check_ret = OB_SUCCESS;
        int add_ret = OB_SUCCESS;
-        if (is_data_not_readable_err(ret)) {
+        if (is_data_not_readable_err(ret) || is_server_down_error(ret)) {
          // 读到落后太多的备机或者正在回放日志的副本了，
          // 将远端的这个observer加进retry info的invalid servers中
          if (OB_UNLIKELY(OB_SUCCESS != (