This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 32373051cd79a29d396694c871622939fb976857
Author: zhannngchen <48427519+zhannngc...@users.noreply.github.com>
AuthorDate: Thu Jan 12 12:10:50 2023 +0800
[enhancement](unique key) disable concurrent flush memtable for unique key
(#15802)
---
be/src/olap/delta_writer.cpp | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/olap/delta_writer.cpp b/be/src/olap/delta_writer.cpp
index 09afa54be9..0a05a03006 100644
--- a/be/src/olap/delta_writer.cpp
+++ b/be/src/olap/delta_writer.cpp
@@ -141,9 +141,9 @@ Status DeltaWriter::init() {
_reset_mem_table();
// create flush handler
- // unique key merge on write should flush serial cause calc delete bitmap
should load segment serial
- bool should_serial = (_tablet->keys_type() == KeysType::UNIQUE_KEYS &&
- _tablet->enable_unique_key_merge_on_write());
+ // unique key should flush serial because we need to make sure same key
should sort
+ // in the same order in all replica.
+ bool should_serial = _tablet->keys_type() == KeysType::UNIQUE_KEYS;
RETURN_NOT_OK(_storage_engine->memtable_flush_executor()->create_flush_token(
&_flush_token, _rowset_writer->type(), should_serial,
_req.is_high_priority));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
