This is an automated email from the ASF dual-hosted git repository.

zhangchen pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.0 by this push:
     new 74a5692336a [enhancement](merge-on-write) compaction should not check 
correctness if tablet is not ready (#33435) (#33597)
74a5692336a is described below

commit 74a5692336af5ebe1bf675edf50f6e0552f14f51
Author: zhannngchen <[email protected]>
AuthorDate: Sat Apr 13 00:14:21 2024 +0800

    [enhancement](merge-on-write) compaction should not check correctness if 
tablet is not ready (#33435) (#33597)
---
 be/src/olap/compaction.cpp | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/be/src/olap/compaction.cpp b/be/src/olap/compaction.cpp
index 36a2ba7f506..6dbaf4865c3 100644
--- a/be/src/olap/compaction.cpp
+++ b/be/src/olap/compaction.cpp
@@ -423,7 +423,8 @@ Status Compaction::do_compaction_impl(int64_t permits) {
         if (!allow_delete_in_cumu_compaction()) {
             missed_rows_size = missed_rows.size();
             if (compaction_type() == ReaderType::READER_CUMULATIVE_COMPACTION 
&&
-                stats.merged_rows != missed_rows_size) {
+                stats.merged_rows != missed_rows_size &&
+                _tablet->tablet_state() == TABLET_RUNNING) {
                 std::string err_msg = fmt::format(
                         "cumulative compaction: the merged rows({}) is not 
equal to missed "
                         "rows({}) in rowid conversion, tablet_id: {}, 
table_id:{}",
@@ -818,7 +819,8 @@ Status Compaction::modify_rowsets(const Merger::Statistics* 
stats) {
         if (!allow_delete_in_cumu_compaction()) {
             missed_rows_size = missed_rows.size();
             if (compaction_type() == ReaderType::READER_CUMULATIVE_COMPACTION 
&& stats != nullptr &&
-                stats->merged_rows != missed_rows_size) {
+                stats->merged_rows != missed_rows_size &&
+                _tablet->tablet_state() == TABLET_RUNNING) {
                 std::string err_msg = fmt::format(
                         "cumulative compaction: the merged rows({}) is not 
equal to missed "
                         "rows({}) in rowid conversion, tablet_id: {}, 
table_id:{}",


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to