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

[fix](vertical compaction) compaction block reader should return error when reading next block failed (#22431)

Browse Source
This commit is contained in:
huanghaibin
2023-08-01 14:09:18 +08:00
committed by GitHub
parent f842067354
commit 43d783ae21
3 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/vec/olap/block_reader.cpp
View File

@ -384,7 +384,7 @@ Status BlockReader::_unique_key_next_block(Block* block, bool* eof) {
std::make_shared<DataTypeUInt8>(),
"__DORIS_COMPACTION_FILTER__"};
block->insert(column_with_type_and_name);
Block::filter_block(block, target_columns.size(), target_columns.size());
RETURN_IF_ERROR(Block::filter_block(block, target_columns.size(), target_columns.size()));
_stats.rows_del_filtered += target_block_row - block->rows();
DCHECK(block->try_get_by_name("__DORIS_COMPACTION_FILTER__") == nullptr);
}