From 2030c44dba6ead853fc97f0b18070ef02febf738 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Sat, 14 Aug 2021 10:25:45 +0800 Subject: [PATCH] [Log] Modify some log level on BE side (#6381) --- be/src/exec/olap_scan_node.cpp | 6 ++++-- be/src/runtime/plan_fragment_executor.cpp | 7 ++++--- .../test/java/org/apache/doris/utframe/UtFrameUtils.java | 2 +- 3 files changed, 9 insertions(+), 6 deletions(-) diff --git a/be/src/exec/olap_scan_node.cpp b/be/src/exec/olap_scan_node.cpp index d97b6c2268..03a6ad920b 100644 --- a/be/src/exec/olap_scan_node.cpp +++ b/be/src/exec/olap_scan_node.cpp @@ -326,7 +326,8 @@ Status OlapScanNode::get_next(RuntimeState* state, RowBatch* row_batch, bool* eo _row_batch_consumed_cv.notify_all(); *eos = true; - LOG(INFO) << "OlapScanNode ReachedLimit."; + VLOG_QUERY << "OlapScanNode ReachedLimit. fragment id=" + << print_id(_runtime_state->fragment_instance_id()); } else { *eos = false; } @@ -1553,7 +1554,8 @@ void OlapScanNode::scanner_thread(OlapScanner* scanner) { if (UNLIKELY(_transfer_done)) { eos = true; status = Status::Cancelled("Cancelled"); - LOG(INFO) << "Scan thread cancelled, cause query done, maybe reach limit."; + VLOG_QUERY << "Scan thread cancelled, cause query done, maybe reach limit." + << ", fragment id=" << print_id(_runtime_state->fragment_instance_id()); break; } RowBatch* row_batch = new RowBatch(this->row_desc(), state->batch_size(), diff --git a/be/src/runtime/plan_fragment_executor.cpp b/be/src/runtime/plan_fragment_executor.cpp index 0040a4f11a..a50744bbde 100644 --- a/be/src/runtime/plan_fragment_executor.cpp +++ b/be/src/runtime/plan_fragment_executor.cpp @@ -135,8 +135,6 @@ Status PlanFragmentExecutor::prepare(const TExecPlanFragmentParams& request, _exec_env->process_mem_tracker(), true, false, MemTrackerLevel::TASK); _runtime_state->set_fragment_mem_tracker(_mem_tracker); - LOG(INFO) << "Using query memory limit: " << PrettyPrinter::print(bytes_limit, TUnit::BYTES); - RETURN_IF_ERROR(_runtime_state->create_block_mgr()); // set up desc tbl @@ -239,7 +237,9 @@ Status PlanFragmentExecutor::prepare(const TExecPlanFragmentParams& request, Status PlanFragmentExecutor::open() { LOG(INFO) << "Open(): fragment_instance_id=" - << print_id(_runtime_state->fragment_instance_id()); + << print_id(_runtime_state->fragment_instance_id()) + << ", Using query memory limit: " + << PrettyPrinter::print(_runtime_state->fragment_mem_tracker()->limit(), TUnit::BYTES); // we need to start the profile-reporting thread before calling Open(), since it // may block @@ -587,6 +587,7 @@ void PlanFragmentExecutor::close() { _runtime_state->runtime_profile()->pretty_print(&ss); LOG(INFO) << ss.str(); } + LOG(INFO) << "Close() fragment_instance_id=" << print_id(_runtime_state->fragment_instance_id()); } // _mem_tracker init failed diff --git a/fe/fe-core/src/test/java/org/apache/doris/utframe/UtFrameUtils.java b/fe/fe-core/src/test/java/org/apache/doris/utframe/UtFrameUtils.java index 7686c0fd29..bec75b4263 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/utframe/UtFrameUtils.java +++ b/fe/fe-core/src/test/java/org/apache/doris/utframe/UtFrameUtils.java @@ -197,7 +197,7 @@ public class UtFrameUtils { be.setOwnerClusterName(SystemInfoService.DEFAULT_CLUSTER); be.setBePort(be_thrift_port); be.setHttpPort(be_http_port); - be.setBeRpcPort(be_brpc_port); + be.setBrpcPort(be_brpc_port); Catalog.getCurrentSystemInfo().addBackend(be); }