fixup

kaijchen · Sep 3, 2024 · 0f1df31 · 0f1df31
1 parent 70aae4b
commit 0f1df31
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
@@ -406,7 +406,6 @@ void FragmentMgr::coordinator_callback(const ReportStatusRequest& req) {
  t.__set_fragment_instance_id(req.runtime_state->fragment_instance_id());
  t.__set_num_finished_range(req.runtime_state->num_finished_range());
  params.fragment_instance_reports.emplace_back(t);
- LOG(INFO) << "[ckj] report params = " << para
  } else if (!req.runtime_states.empty()) {
  for (auto* rs : req.runtime_states) {
  if (rs->num_rows_load_total() > 0 || rs->num_rows_load_filtered() > 0 ||

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -2449,6 +2449,7 @@ public void updateFragmentExecStatus(TReportExecStatusParams params) {
  }
 
  if (params.isSetLoadedRows() && jobId != -1) {
+ LOG.info("[debug][DORIS-12389] got fragment instance reports: {}", params);
  if (params.isSetFragmentInstanceReports()) {
  for (TFragmentInstanceReport instance : params.getFragmentInstanceReports()) {
  Env.getCurrentEnv().getLoadManager().updateJobProgress(