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 ba05ef44055 [Chore](runtime-filter) add tmp debug info to investigate
unknown filter error #33857
ba05ef44055 is described below
commit ba05ef440555ab5facb291781804f36393d85224
Author: Pxl <[email protected]>
AuthorDate: Thu Apr 18 21:03:09 2024 +0800
[Chore](runtime-filter) add tmp debug info to investigate unknown filter
error #33857
---
be/src/runtime/runtime_filter_mgr.cpp | 5 +++++
be/src/runtime/runtime_state.cpp | 6 ++++++
2 files changed, 11 insertions(+)
diff --git a/be/src/runtime/runtime_filter_mgr.cpp
b/be/src/runtime/runtime_filter_mgr.cpp
index 65c1852625b..9f3d26d6a16 100644
--- a/be/src/runtime/runtime_filter_mgr.cpp
+++ b/be/src/runtime/runtime_filter_mgr.cpp
@@ -72,6 +72,11 @@ 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()) {
+ std::string keys;
+ for (auto it : _consumer_map) {
+ keys += std::to_string(it.first) + ",";
+ }
+ LOG(WARNING) << "add: " << this << " ,keys:" << keys << " ,filter_id:"
<< filter_id;
return Status::InternalError("get_consume_filters meet unknown filter:
{}, role: CONSUMER.",
filter_id);
}
diff --git a/be/src/runtime/runtime_state.cpp b/be/src/runtime/runtime_state.cpp
index aab31fa02ea..a541b2d2adc 100644
--- a/be/src/runtime/runtime_state.cpp
+++ b/be/src/runtime/runtime_state.cpp
@@ -547,9 +547,15 @@ Status
RuntimeState::register_consumer_runtime_filter(const doris::TRuntimeFilte
bool need_local_merge,
int node_id,
doris::IRuntimeFilter**
consumer_filter) {
if (desc.has_remote_targets || need_local_merge) {
+ LOG(WARNING) << "registe global ins:" << _profile.name()
+ << " ,mgr: " << global_runtime_filter_mgr()
+ << " ,filter id:" << desc.filter_id;
return global_runtime_filter_mgr()->register_consumer_filter(desc,
query_options(), node_id,
consumer_filter, false, true);
} else {
+ LOG(WARNING) << "registe local ins:" << _profile.name()
+ << " ,mgr: " << global_runtime_filter_mgr()
+ << " ,filter id:" << desc.filter_id;
return local_runtime_filter_mgr()->register_consumer_filter(desc,
query_options(), node_id,
consumer_filter, false, false);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
