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 6ce61eb5fc3 [Chore](status) change unknow filter error to internal
error (#33633)
6ce61eb5fc3 is described below
commit 6ce61eb5fc3732081471c27ee655891edcac2bc5
Author: Pxl <[email protected]>
AuthorDate: Sun Apr 14 16:44:21 2024 +0800
[Chore](status) change unknow filter error to internal error (#33633)
---
be/src/runtime/runtime_filter_mgr.cpp | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/be/src/runtime/runtime_filter_mgr.cpp
b/be/src/runtime/runtime_filter_mgr.cpp
index f1adb4ed198..65c1852625b 100644
--- a/be/src/runtime/runtime_filter_mgr.cpp
+++ b/be/src/runtime/runtime_filter_mgr.cpp
@@ -72,7 +72,8 @@ Status RuntimeFilterMgr::get_consume_filters(const int
filter_id,
std::lock_guard<std::mutex> l(_lock);
auto iter = _consumer_map.find(filter_id);
if (iter == _consumer_map.end()) {
- return Status::InvalidArgument("unknown filter: {}, role: CONSUMER.",
filter_id);
+ return Status::InternalError("get_consume_filters meet unknown filter:
{}, role: CONSUMER.",
+ filter_id);
}
for (auto& holder : iter->second) {
consumer_filters.emplace_back(holder.filter);
@@ -153,8 +154,10 @@ Status RuntimeFilterMgr::get_local_merge_producer_filters(
std::lock_guard<std::mutex> l(_lock);
auto iter = _local_merge_producer_map.find(filter_id);
if (iter == _local_merge_producer_map.end()) {
- return Status::InvalidArgument("unknown filter: {}, role:
LOCAL_MERGE_PRODUCER.",
- filter_id);
+ return Status::InternalError(
+ "get_local_merge_producer_filters meet unknown filter: {},
role: "
+ "LOCAL_MERGE_PRODUCER.",
+ filter_id);
}
*local_merge_filters = &iter->second;
DCHECK(!iter->second.filters.empty());
@@ -194,7 +197,8 @@ Status RuntimeFilterMgr::update_filter(const
PPublishFilterRequest* request,
std::lock_guard<std::mutex> l(_lock);
auto iter = _consumer_map.find(filter_id);
if (iter == _consumer_map.end()) {
- return Status::InvalidArgument("unknown filter: {}, role:
CONSUMER.", filter_id);
+ return Status::InternalError("update_filter meet unknown filter:
{}, role: CONSUMER.",
+ filter_id);
}
for (auto& holder : iter->second) {
filters.emplace_back(holder.filter);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
