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

Fix: swallow error code

Browse Source
This commit is contained in:
yaojing624 2024-06-25 17:03:45 +00:00 committed by ob-robot
parent 13de62425e
commit bd76a37642
1 changed files with 70 additions and 68 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

138
src/sql/engine/set/ob_hash_union_vec_op.cpp
View File

@ -106,79 +106,81 @@ int ObHashUnionVecOp::inner_get_next_batch(const int64_t max_row_cnt)
ObBitVector *output_vec = nullptr;
const ObBatchRows *child_brs = nullptr;
if (!has_got_part_) {
if (child_op_end) {
end_to_process = true;
} else if (OB_FAIL(get_child_next_batch(batch_size, child_brs))) {
LOG_WARN("failed to get child next batch", K(ret));
} else if (OB_FAIL(convert_vector(cur_child_op_->get_spec().output_,
MY_SPEC.set_exprs_,
child_brs))) {
LOG_WARN("copy current row failed", K(ret));
} else if (OB_FAIL(hp_infras_.calc_hash_value_for_batch(MY_SPEC.set_exprs_,
*child_brs,
hash_values_for_batch_))) {
LOG_WARN("failed to calc hash value for batch", K(ret));
} else {
child_op_end = cur_child_op_ == right_ && child_brs->end_ && 0 != child_brs->size_;
end_to_process = cur_child_op_ == right_ && child_brs->end_ && 0 == child_brs->size_;
read_rows = child_brs->size_;
}
} else if (OB_FAIL(hp_infras_.get_left_next_batch(MY_SPEC.set_exprs_,
batch_size,
read_rows,
hash_values_for_batch_))) {
if (OB_ITER_END == ret) {
ret = OB_SUCCESS;
end_to_process = true;
} else {
LOG_WARN("failed to get batch from infra", K(ret));
}
}
if (OB_SUCC(ret) && end_to_process) {
end_to_process = false;
if (OB_FAIL(hp_infras_.finish_insert_row())) {
LOG_WARN("failed to finish insert row", K(ret));
} else if (!has_got_part_) {
has_got_part_ = true;
} else if (OB_FAIL(hp_infras_.close_cur_part(InputSide::LEFT))) {
LOG_WARN("failed to close cur part", K(ret));
}
if (OB_FAIL(ret)) {
} else if (OB_FAIL(hp_infras_.end_round())) {
LOG_WARN("failed to end round", K(ret));
} else if (OB_FAIL(try_check_status())) {
LOG_WARN("failed to check status", K(ret));
} else if (OB_FAIL(hp_infras_.start_round())) {
LOG_WARN("failed to start round", K(ret));
} else if (OB_FAIL(hp_infras_.get_next_partition(InputSide::LEFT))) {
if (OB_ITER_END != ret) {
LOG_WARN("failed to get next dumped partition", K(ret));
if (OB_SUCC(ret)) {
if (!has_got_part_) {
if (child_op_end) {
end_to_process = true;
} else if (OB_FAIL(get_child_next_batch(batch_size, child_brs))) {
LOG_WARN("failed to get child next batch", K(ret));
} else if (OB_FAIL(convert_vector(cur_child_op_->get_spec().output_,
MY_SPEC.set_exprs_,
child_brs))) {
LOG_WARN("copy current row failed", K(ret));
} else if (OB_FAIL(hp_infras_.calc_hash_value_for_batch(MY_SPEC.set_exprs_,
*child_brs,
hash_values_for_batch_))) {
LOG_WARN("failed to calc hash value for batch", K(ret));
} else {
child_op_end = cur_child_op_ == right_ && child_brs->end_ && 0 != child_brs->size_;
end_to_process = cur_child_op_ == right_ && child_brs->end_ && 0 == child_brs->size_;
read_rows = child_brs->size_;
}
} else if (OB_FAIL(hp_infras_.get_left_next_batch(MY_SPEC.set_exprs_,
batch_size,
read_rows,
hash_values_for_batch_))) {
if (OB_ITER_END == ret) {
ret = OB_SUCCESS;
end_to_process = true;
} else {
LOG_WARN("failed to get batch from infra", K(ret));
}
} else if (OB_FAIL(hp_infras_.open_cur_part(InputSide::LEFT))) {
LOG_WARN("failed to open cur part", K(ret));
} else if (OB_FAIL(hp_infras_.resize(hp_infras_.get_cur_part_row_cnt(InputSide::LEFT)))) {
LOG_WARN("failed to resize cur part", K(ret));
}
} else if (OB_FAIL(ret)) {
} else if (has_got_part_ && OB_FAIL(hp_infras_.insert_row_for_batch(MY_SPEC.set_exprs_,
hash_values_for_batch_,
read_rows,
nullptr,
output_vec))) {
LOG_WARN("failed to insert batch for dump", K(ret));
} else if (!has_got_part_ && OB_FAIL(hp_infras_.insert_row_for_batch(MY_SPEC.set_exprs_,
if (OB_SUCC(ret) && end_to_process) {
end_to_process = false;
if (OB_FAIL(hp_infras_.finish_insert_row())) {
LOG_WARN("failed to finish insert row", K(ret));
} else if (!has_got_part_) {
has_got_part_ = true;
} else if (OB_FAIL(hp_infras_.close_cur_part(InputSide::LEFT))) {
LOG_WARN("failed to close cur part", K(ret));
}
if (OB_FAIL(ret)) {
} else if (OB_FAIL(hp_infras_.end_round())) {
LOG_WARN("failed to end round", K(ret));
} else if (OB_FAIL(try_check_status())) {
LOG_WARN("failed to check status", K(ret));
} else if (OB_FAIL(hp_infras_.start_round())) {
LOG_WARN("failed to start round", K(ret));
} else if (OB_FAIL(hp_infras_.get_next_partition(InputSide::LEFT))) {
if (OB_ITER_END != ret) {
LOG_WARN("failed to get next dumped partition", K(ret));
}
} else if (OB_FAIL(hp_infras_.open_cur_part(InputSide::LEFT))) {
LOG_WARN("failed to open cur part", K(ret));
} else if (OB_FAIL(hp_infras_.resize(hp_infras_.get_cur_part_row_cnt(InputSide::LEFT)))) {
LOG_WARN("failed to resize cur part", K(ret));
}
} else if (OB_FAIL(ret)) {
} else if (has_got_part_ && OB_FAIL(hp_infras_.insert_row_for_batch(MY_SPEC.set_exprs_,
hash_values_for_batch_,
read_rows,
child_brs->skip_,
nullptr,
output_vec))) {
LOG_WARN("failed to insert batch for no dump", K(ret));
} else if (OB_ISNULL(output_vec)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("failed to get output vec", K(ret));
} else {
brs_.size_ = read_rows;
brs_.skip_->deep_copy(*output_vec, read_rows);
LOG_WARN("failed to insert batch for dump", K(ret));
} else if (!has_got_part_ && OB_FAIL(hp_infras_.insert_row_for_batch(MY_SPEC.set_exprs_,
hash_values_for_batch_,
read_rows,
child_brs->skip_,
output_vec))) {
LOG_WARN("failed to insert batch for no dump", K(ret));
} else if (OB_ISNULL(output_vec)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("failed to get output vec", K(ret));
} else {
brs_.size_ = read_rows;
brs_.skip_->deep_copy(*output_vec, read_rows);
}
}