You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/12/01 07:00:23 UTC
[doris] 08/10: [fix](join) runtime filter shared from other instance wasn't be published (#14717)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-unstable
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 96613e2c731240df19402500990c2aed32ec9354
Author: Jerry Hu <mr...@gmail.com>
AuthorDate: Thu Dec 1 14:17:23 2022 +0800
[fix](join) runtime filter shared from other instance wasn't be published (#14717)
---
be/src/vec/exec/join/vhash_join_node.cpp | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/be/src/vec/exec/join/vhash_join_node.cpp b/be/src/vec/exec/join/vhash_join_node.cpp
index 35b83e2a8d..13337a2e83 100644
--- a/be/src/vec/exec/join/vhash_join_node.cpp
+++ b/be/src/vec/exec/join/vhash_join_node.cpp
@@ -765,8 +765,10 @@ Status HashJoinNode::_materialize_build_side(RuntimeState* state) {
RETURN_IF_ERROR(_runtime_filter_slots->init(
state, arg.hash_table.get_size()));
- return _runtime_filter_slots->copy_from_shared_context(
- _shared_hash_table_context);
+ RETURN_IF_ERROR(_runtime_filter_slots->copy_from_shared_context(
+ _shared_hash_table_context));
+ _runtime_filter_slots->publish();
+ return Status::OK();
}},
*_hash_table_variants);
RETURN_IF_ERROR(ret);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org