Skip to content

Commit

Permalink
f
Browse files Browse the repository at this point in the history
  • Loading branch information
Doris-Extras committed Sep 23, 2024
1 parent d739382 commit 2bbc5da
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion be/src/runtime/query_context.h
Original file line number Diff line number Diff line change
Expand Up @@ -323,7 +323,7 @@ class QueryContext : public std::enable_shared_from_this<QueryContext> {

void update_paused_state(const Status& st) {
std::lock_guard l(_paused_mutex);
if (_paused_error_status.is<ErrorCode::QUERY_MEMORY_EXCEED>) {
if (_paused_error_status.is<ErrorCode::QUERY_MEMORY_EXCEED>()) {
return;
} else {
_paused_error_status = st;
Expand Down
2 changes: 1 addition & 1 deletion be/src/runtime/workload_group/workload_group_manager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -378,7 +378,7 @@ void WorkloadGroupMgr::handle_paused_queries() {
query_it = queries_list.erase(query_it);
continue;
}
if (query_ctx->paused_status().is<ErrorCode::QUERY_MEMORY_EXCEED>) {
if (query_ctx->paused_status().is<ErrorCode::QUERY_MEMORY_EXCEED>()) {
// TODO
// If the query is an insert into select query, should consider memtable as revoke memory.
auto revocable_tasks = max_revocable_query->get_revocable_tasks();
Expand Down

0 comments on commit 2bbc5da

Please sign in to comment.