This is an automated email from the ASF dual-hosted git repository. panxiaolei pushed a commit to branch dev_join in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9eecb95dd05e936b4bea56c1cdb3acb0ffba95e8 Author: HappenLee <[email protected]> AuthorDate: Thu Oct 26 10:48:09 2023 +0800 fix some bug of tpch (#25931) --- be/src/vec/common/hash_table/hash_map.h | 1 - be/src/vec/exec/join/process_hash_table_probe_impl.h | 3 +-- be/src/vec/exec/join/vhash_join_node.cpp | 1 - 3 files changed, 1 insertion(+), 4 deletions(-) diff --git a/be/src/vec/common/hash_table/hash_map.h b/be/src/vec/common/hash_table/hash_map.h index 35abaf48fff..1c132fc99ed 100644 --- a/be/src/vec/common/hash_table/hash_map.h +++ b/be/src/vec/common/hash_table/hash_map.h @@ -373,7 +373,6 @@ private: build_idx = first[bucket_nums[probe_idx]]; do_the_probe(); } - if (matched_cnt == batch_size && build_idx) { probe_idx--; current_probe_idx = probe_idx; diff --git a/be/src/vec/exec/join/process_hash_table_probe_impl.h b/be/src/vec/exec/join/process_hash_table_probe_impl.h index a82e6adb8b3..a267a96d55f 100644 --- a/be/src/vec/exec/join/process_hash_table_probe_impl.h +++ b/be/src/vec/exec/join/process_hash_table_probe_impl.h @@ -148,14 +148,13 @@ Status ProcessHashTableProbe<JoinOpType, Parent>::do_process(HashTableType& hash Block* output_block, size_t probe_rows) { auto& probe_index = _parent->_probe_index; + auto last_probe_index = probe_index; _init_probe_side<HashTableType>(hash_table_ctx, probe_rows, with_other_conjuncts, need_null_map_for_probe ? null_map->data() : nullptr); auto& mcol = mutable_block.mutable_columns(); - int last_probe_index = probe_index; - int current_offset = 0; bool all_match_one = false; size_t probe_size = 0; diff --git a/be/src/vec/exec/join/vhash_join_node.cpp b/be/src/vec/exec/join/vhash_join_node.cpp index cd2d4eb6445..9e8c99c8d56 100644 --- a/be/src/vec/exec/join/vhash_join_node.cpp +++ b/be/src/vec/exec/join/vhash_join_node.cpp @@ -98,7 +98,6 @@ HashJoinNode::HashJoinNode(ObjectPool* pool, const TPlanNode& tnode, const Descr _arena = std::make_shared<Arena>(); _hash_table_variants = std::make_shared<HashTableVariants>(); _process_hashtable_ctx_variants = std::make_unique<HashTableCtxVariants>(); - _build_block = std::make_shared<Block>(); } Status HashJoinNode::init(const TPlanNode& tnode, RuntimeState* state) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
