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

fix core in nlj

Browse Source
This commit is contained in:
obdev
2023-02-08 15:08:46 +08:00
committed by ob-robot
parent fbc39031c6
commit c129aa89d0
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/sql/engine/basic/ob_group_join_buffer.h
View File

@ -81,6 +81,7 @@ public:
int batch_fill_group_buffer(const int64_t max_row_cnt, const ObBatchRows *&batch_rows); int batch_fill_group_buffer(const int64_t max_row_cnt, const ObBatchRows *&batch_rows);
int get_next_row_from_store(); int get_next_row_from_store();
int get_next_batch_from_store(int64_t max_rows, int64_t &read_rows); int get_next_batch_from_store(int64_t max_rows, int64_t &read_rows);
ObBatchRowDatums &get_last_batch() { return last_batch_; }
void destroy(); void destroy();
private: private:
int init_group_params(); int init_group_params();

4
src/sql/engine/join/ob_nested_loop_join_op.cpp
View File

@ -847,7 +847,9 @@ int ObNestedLoopJoinOp::process_right_batch()
} else { } else {
if (MY_SPEC.enable_px_batch_rescan_) { if (MY_SPEC.enable_px_batch_rescan_) {
last_save_batch_.extend_save(eval_ctx_, right_brs->size_); last_save_batch_.extend_save(eval_ctx_, right_brs->size_);
} else if (!MY_SPEC.group_rescan_) { } else if (MY_SPEC.group_rescan_) {
group_join_buffer_.get_last_batch().extend_save(eval_ctx_, right_brs->size_);
} else {
left_batch_.extend_save(eval_ctx_, right_brs->size_); left_batch_.extend_save(eval_ctx_, right_brs->size_);
} }
left_expr_extend(right_brs->size_); left_expr_extend(right_brs->size_);