diff --git a/be/src/exec/pipeline/exec_state_reporter.cpp b/be/src/exec/pipeline/exec_state_reporter.cpp
index 62f9a95f58e3e..f5cef836af2df 100644
--- a/be/src/exec/pipeline/exec_state_reporter.cpp
+++ b/be/src/exec/pipeline/exec_state_reporter.cpp
@@ -171,6 +171,7 @@ Status ExecStateReporter::report_exec_status(const TReportExecStatusParams& para
                 }
                 coord->reportExecStatus(res, params);
             } else {
+                (void)coord.reopen(config::thrift_rpc_timeout_ms);
                 std::stringstream msg;
                 msg << "ReportExecStatus() to " << fe_addr << " failed:\n" << e.what();
                 LOG(WARNING) << msg.str();
@@ -285,6 +286,7 @@ Status ExecStateReporter::report_epoch(const TMVMaintenanceTasks& params, ExecEn
                 }
                 coord->mvReport(res, params);
             } else {
+                (void)coord.reopen(config::thrift_rpc_timeout_ms);
                 std::stringstream msg;
                 msg << "mvReport() to " << fe_addr << " failed:\n" << e.what();
                 LOG(WARNING) << msg.str();