This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new de61887cdc8 [chore](log) reduce print warning msg during be starting
up #36710 (#37780)
de61887cdc8 is described below
commit de61887cdc8d721fbccb51ee48b9fa34339012aa
Author: zhiqiang <[email protected]>
AuthorDate: Mon Jul 15 14:46:54 2024 +0800
[chore](log) reduce print warning msg during be starting up #36710 (#37780)
cherry pick from #36710
---
be/src/runtime/fragment_mgr.cpp | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 6846782dd8e..8ceeff10481 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -1162,10 +1162,11 @@ void FragmentMgr::cancel_worker() {
// 1. If query's process uuid is zero, do not cancel
// 2. If same process uuid, do not cancel
// 3. If fe has zero process uuid, do not cancel
- if (running_fes.empty()) {
+ if (running_fes.empty() && !_query_ctx_map.empty()) {
LOG_EVERY_N(WARNING, 10)
- << "Could not find any running frontends, maybe we are
upgrading? "
- << "We will not cancel any running queries in this
situation.";
+ << "Could not find any running frontends, maybe we are
upgrading or "
+ "starting? "
+ << "We will not cancel any outdated queries in this
situation.";
} else {
for (const auto& q : _query_ctx_map) {
if (q.second->get_fe_process_uuid() == 0) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
