diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp index 6846782dd8..8ceeff1048 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) {