[BugFix] Fix thrift invalid TType error (backport StarRocks#50276) (S…

…tarRocks#50289) Co-authored-by: stdpain <[email protected]>
DanJing-coder · Aug 27, 2024 · b472563 · b472563
1 parent 9f7b6d6
commit b472563
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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();