This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b55195bd80 [FixAssist](compaction) add DCHECK in
BlockReader::_unique_key_next_block to reason problem (#11951)
b55195bd80 is described below
commit b55195bd8026baab045165e99101c141f4875d61
Author: Yongqiang YANG <[email protected]>
AuthorDate: Mon Aug 22 22:33:31 2022 +0800
[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<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();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
