From b55195bd8026baab045165e99101c141f4875d61 Mon Sep 17 00:00:00 2001 From: Yongqiang YANG <98214048+dataroaring@users.noreply.github.com> Date: Mon, 22 Aug 2022 22:33:31 +0800 Subject: [PATCH] [FixAssist](compaction) add DCHECK in BlockReader::_unique_key_next_block to reason problem (#11951) --- be/src/vec/olap/block_reader.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/be/src/vec/olap/block_reader.cpp b/be/src/vec/olap/block_reader.cpp index a42e7dbd56..cb1c1aa263 100644 --- a/be/src/vec/olap/block_reader.cpp +++ b/be/src/vec/olap/block_reader.cpp @@ -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(), "filter"}; + ColumnWithTypeAndName column_with_type_and_name {_delete_filter_column, + std::make_shared(), + "__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(); }