-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Unify the msg of 'Memory exceed limit' #1737
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
The new msg of limit exceed: "Memory exceed limit. %msg, Backend:%ip, fragment:%id Used:% , Limit:%. xxx". This commit unifies the msg of 'Memory exceed limit' such as check_query_state, RETURN_IF_LIMIT_EXCEEDED and LIMIT_EXCEEDED.
be/src/exec/sort_node.cpp
Outdated
| "Sort node was getting next from the child."); | ||
| std::stringstream msg; | ||
| msg << "Sort, while getting next from the child."; | ||
| RETURN_IF_LIMIT_EXCEEDED(state, msg.str()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| RETURN_IF_LIMIT_EXCEEDED(state, msg.str()); | |
| RETURN_IF_LIMIT_EXCEEDED(state, "Sort, while getting next from the child."); |
| RETURN_IF_ERROR(state->check_query_state()); | ||
| std::stringstream msg; | ||
| msg << "Partitioned aggregation, while getting next from child 0."; | ||
| RETURN_IF_ERROR(state->check_query_state(msg.str())); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| RETURN_IF_ERROR(state->check_query_state(msg.str())); | |
| RETURN_IF_ERROR(state->check_query_state("Partitioned aggregation, while getting next from child 0.")); |
| if (_status.ok()) { | ||
| if (status.is_mem_limit_exceeded()) { | ||
| _runtime_state->set_mem_limit_exceeded(); | ||
| _runtime_state->set_mem_limit_exceeded(status.get_error_msg()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| _runtime_state->set_mem_limit_exceeded(status.get_error_msg()); | |
| _runtime_state->set_mem_limit_exceeded(status.to_string()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
set_mem_limit_exceeded already set the code of MemoryLimitExceeded
| } | ||
| std::stringstream msg; | ||
| msg << "Buffered block mgr, while getting new block"; | ||
| RETURN_IF_LIMIT_EXCEEDED(_state, msg.str()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No need to use stringstream
The new msg of limit exceed: "Memory exceed limit. %msg, Backend:%ip, fragment:%id Used:% , Limit:%. xxx".
This commit unifies the msg of 'Memory exceed limit' such as check_query_state, RETURN_IF_LIMIT_EXCEEDED and LIMIT_EXCEEDED.