From b472563f2d1313c5c13218d6ed6c99b19a2f974d Mon Sep 17 00:00:00 2001
From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com>
Date: Tue, 27 Aug 2024 02:38:04 +0000
Subject: [PATCH] [BugFix] Fix thrift invalid TType error (backport #50276)
 (#50289)

Co-authored-by: stdpain <34912776+stdpain@users.noreply.github.com>
---
 be/src/exec/pipeline/exec_state_reporter.cpp | 2 ++
 1 file changed, 2 insertions(+)

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();