hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix hash join NL mode do not inc age leads 4013

Browse Source
This commit is contained in:
obdev
2024-02-08 23:01:28 +00:00
committed by ob-robot
parent 437a6a5c00
commit 7e63c3096d
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp
View File

@ -829,8 +829,8 @@ int ObHashJoinVecOp::build_hash_table_for_nest_loop(int64_t &num_left_rows)
int64_t memory_bound = std::max(remain_data_memory_size_, int64_t memory_bound = std::max(remain_data_memory_size_,
hj_part->get_row_store().get_max_blk_size()); hj_part->get_row_store().get_max_blk_size());
const int64_t row_bound = min(hash_table.get_row_count(), hash_table.get_nbuckets() / 2); const int64_t row_bound = min(hash_table.get_row_count(), hash_table.get_nbuckets() / 2);
ObTempRowStore::IterationAge iter_age; hj_part->set_iteration_age(iter_age_);
hj_part->set_iteration_age(iter_age); iter_age_.inc();
JoinPartitionRowIter left_iter(hj_part, row_bound, memory_bound); JoinPartitionRowIter left_iter(hj_part, row_bound, memory_bound);
ret = hash_table.build(left_iter, jt_ctx_); ret = hash_table.build(left_iter, jt_ctx_);
} }
@ -1212,8 +1212,8 @@ int ObHashJoinVecOp::build_hash_table_in_memory(int64_t &num_left_rows)
} else if (OB_FAIL(prepare_hash_table())) { } else if (OB_FAIL(prepare_hash_table())) {
LOG_WARN("failed to prepare hash table", K(ret)); LOG_WARN("failed to prepare hash table", K(ret));
} else { } else {
ObTempRowStore::IterationAge iter_age; hj_part->set_iteration_age(iter_age_);
hj_part->set_iteration_age(iter_age); iter_age_.inc();
JoinPartitionRowIter left_iter(hj_part); JoinPartitionRowIter left_iter(hj_part);
ret = hash_table.build(left_iter, jt_ctx_); ret = hash_table.build(left_iter, jt_ctx_);
} }

1
src/sql/engine/join/hash_join/ob_hash_join_vec_op.h
View File

@ -600,6 +600,7 @@ private:
bool skip_right_null_; bool skip_right_null_;
OutputInfo output_info_; OutputInfo output_info_;
ObTempRowStore::IterationAge iter_age_;
}; };
} // end namespace sql } // end namespace sql