update 2

Signed-off-by: liuyehcf <1559500551@qq.com>
StarRocks · Aug 28, 2023 · f64dc1e · f64dc1e
1 parent 529893a
commit f64dc1e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/be/src/exec/pipeline/audit_statistics_reporter.cpp b/be/src/exec/pipeline/audit_statistics_reporter.cpp
@@ -60,6 +60,7 @@ Status AuditStatisticsReporter::report_audit_statistics(const TReportAuditStatis
                 msg << "ReportExecStatus() to " << fe_addr << " failed:\n" << e.what();
                 LOG(WARNING) << msg.str();
                 rpc_status = Status::InternalError(msg.str());
+                return rpc_status;
             }
         }
 
@@ -69,6 +70,7 @@ Status AuditStatisticsReporter::report_audit_statistics(const TReportAuditStatis
         msg << "ReportExecStatus() to " << fe_addr << " failed:\n" << e.what();
         LOG(WARNING) << msg.str();
         rpc_status = Status::InternalError(msg.str());
+        return rpc_status;
     }
     return rpc_status;
 }

diff --git a/be/src/exec/pipeline/exec_state_reporter.cpp b/be/src/exec/pipeline/exec_state_reporter.cpp
@@ -162,6 +162,7 @@ Status ExecStateReporter::report_exec_status(const TReportExecStatusParams& para
                 msg << "ReportExecStatus() to " << fe_addr << " failed:\n" << e.what();
                 LOG(WARNING) << msg.str();
                 rpc_status = Status::InternalError(msg.str());
+                return rpc_status;
             }
         }
 
@@ -171,6 +172,7 @@ Status ExecStateReporter::report_exec_status(const TReportExecStatusParams& para
         msg << "ReportExecStatus() to " << fe_addr << " failed:\n" << e.what();
         LOG(WARNING) << msg.str();
         rpc_status = Status::InternalError(msg.str());
+        return rpc_status;
     }
     return rpc_status;
 }

diff --git a/gensrc/thrift/FrontendService.thrift b/gensrc/thrift/FrontendService.thrift
@@ -708,8 +708,8 @@ struct TReportExecStatusParams {
 }
 
 struct TReportAuditStatisticsParams {
-    1: required Types.TUniqueId query_id
-    2: required Types.TUniqueId fragment_instance_id
+    1: optional Types.TUniqueId query_id
+    2: optional Types.TUniqueId fragment_instance_id
     3: optional i64 scan_rows
     4: optional i64 scan_bytes
     5: optional i64 returned_rows