cherry pick from #36710
This commit is contained in:
@ -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) {
|
||||
|
||||
Reference in New Issue
Block a user