database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Enhancement](compaction) return error instead of core when ctx not valid (#18363)

Browse Source
This commit is contained in:
yixiutt
2023-04-04 12:27:13 +08:00
committed by GitHub
parent 54dbb4af67
commit 0cada3f81d
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/vec/olap/vertical_merge_iterator.cpp
View File

@ -542,6 +542,10 @@ Status VerticalMaskMergeIterator::unique_key_next_row(vectorized::IteratorRowRef
auto& ctx = _origin_iter_ctx[order];
RETURN_IF_ERROR(ctx->init(_opts));
DCHECK(ctx->valid());
if (!ctx->valid()) {
LOG(INFO) << "VerticalMergeIteratorContext not valid";
return Status::InternalError("VerticalMergeIteratorContext not valid");
}
if (UNLIKELY(ctx->is_first_row()) && !row_source.agg_flag()) {
// first row in block, don't call ctx->advance
@ -576,6 +580,10 @@ Status VerticalMaskMergeIterator::next_batch(Block* block) {
auto& ctx = _origin_iter_ctx[order];
RETURN_IF_ERROR(ctx->init(_opts));
DCHECK(ctx->valid());
if (!ctx->valid()) {
LOG(INFO) << "VerticalMergeIteratorContext not valid";
return Status::InternalError("VerticalMergeIteratorContext not valid");
}
// find max same source count in cur ctx
size_t limit = std::min(ctx->remain_rows(), _block_row_max - rows);