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

[FixAssist](compaction) add DCHECK in BlockReader::_unique_key_next_block to reason problem (#11951)

Browse Source
This commit is contained in:
Yongqiang YANG
2022-08-22 22:33:31 +08:00
committed by GitHub
parent 68e2b3db44
commit b55195bd80
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -294,11 +294,13 @@ Status BlockReader::_unique_key_next_block(Block* block, MemPool* mem_pool, Obje
filter_data[i] = delete_data[i] == 0;
}
ColumnWithTypeAndName column_with_type_and_name {
_delete_filter_column, std::make_shared<DataTypeUInt8>(), "filter"};
ColumnWithTypeAndName column_with_type_and_name {_delete_filter_column,
std::make_shared<DataTypeUInt8>(),
"__DORIS_COMPACTION_FILTER__"};
block->insert(column_with_type_and_name);
Block::filter_block(block, delete_sign_idx, target_columns.size());
_stats.rows_del_filtered += target_block_row - block->rows();
DCHECK(block->try_get_by_name("__DORIS_COMPACTION_FILTER__") == nullptr);
}
return Status::OK();
}