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

fix vectorize 2.0 format error in old operator last batch

Browse Source
This commit is contained in:
18523270951@163.com
2024-02-20 07:53:17 +00:00
committed by ob-robot
parent 513240666d
commit b0fefbeb0e
2 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/sql/engine/ob_operator.cpp
View File

@ -1332,6 +1332,17 @@ int ObOperator::get_next_batch(const int64_t max_row_cnt, const ObBatchRows *&ba
}
}
if (brs_.end_ && 0 == brs_.size_) {
FOREACH_CNT_X(e, spec_.output_, OB_SUCC(ret)) {
if (UINT32_MAX != (*e)->vector_header_off_) {
if (OB_FAIL((*e)->init_vector(eval_ctx_, (*e)->is_batch_result()
? VEC_UNIFORM : VEC_UNIFORM_CONST, brs_.size_))) {
LOG_WARN("failed to init vector", K(ret));
}
}
}
}
if (OB_SUCC(ret)) {
if (brs_.end_ && brs_.size_ >= 0) {
batch_reach_end_ = true; // prepare to be end

2
src/sql/engine/px/exchange/ob_px_ms_receive_vec_op.cpp
View File

@ -154,7 +154,7 @@ int ObPxMSReceiveVecOp::inner_open()
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("failed to alloc memory for selector", K(ret));
} else if (OB_ISNULL(stored_compact_rows_ = static_cast<const ObCompactRow **>(
ctx_.get_allocator().alloc(spec_.max_batch_size_ * sizeof(ObCompactRow))))) {
ctx_.get_allocator().alloc(spec_.max_batch_size_ * sizeof(ObCompactRow *))))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("failed to alloc memory for stored compact rows", K(ret));
} else {