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

Fix section code REVERSE_ INULL, DIVIDE_ BY_ ZERO's problem

Browse Source
This commit is contained in:
obdev
2024-02-09 06:37:54 +00:00
committed by ob-robot
parent 604130543f
commit 42af945db5
3 changed files with 35 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/sql/dtl/ob_dtl_vectors_buffer.cpp
View File

@ -321,24 +321,29 @@ int ObDtlVectors::init(const common::ObIArray<ObExpr*> &exprs, ObEvalCtx &ctx)
}
}
if (OB_SUCC(ret) && *col_cnt_ > 0) {
row_size_ = row_size;
row_limit_ = remain_size / row_size;
if (row_size * row_limit_ + *col_cnt_ * ObBitVector::memory_size(row_limit_) > remain_size) {
row_limit_ = (remain_size - *col_cnt_ * ObBitVector::memory_size(row_limit_)) / row_size;
}
if (row_limit_ <= 0) {
ret =OB_ERR_UNEXPECTED;
LOG_WARN("failed to calc max row cnt", K(remain_size), K(row_size), K(ret));
} else {
for (int64_t i = 0; i < exprs.count(); ++i) {
VectorInfo &info = infos_[i];
info.nulls_offset_ = pos;
ObBitVector *nulls = to_bit_vector(buf_ + pos);
nulls->reset(row_limit_);
pos += ObBitVector::memory_size(row_limit_);
info.data_offset_ = pos;
pos += row_limit_ * info.fixed_len_;
if (row_size != 0){
row_size_ = row_size;
row_limit_ = remain_size / row_size;
if (row_size * row_limit_ + *col_cnt_ * ObBitVector::memory_size(row_limit_) > remain_size) {
row_limit_ = (remain_size - *col_cnt_ * ObBitVector::memory_size(row_limit_)) / row_size;
}
if (row_limit_ <= 0) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("failed to calc max row cnt", K(remain_size), K(row_size), K(ret));
} else {
for (int64_t i = 0; i < exprs.count(); ++i) {
VectorInfo &info = infos_[i];
info.nulls_offset_ = pos;
ObBitVector *nulls = to_bit_vector(buf_ + pos);
nulls->reset(row_limit_);
pos += ObBitVector::memory_size(row_limit_);
info.data_offset_ = pos;
pos += row_limit_ * info.fixed_len_;
}
}
} else {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected row_size", K(row_size), K(ret));
}
}
}