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
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new de2bc98fa2 [bugfix](compaction) remove useless check #17804
de2bc98fa2 is described below
commit de2bc98fa26d30136b9864275e184d28ae72e96b
Author: morningman <[email protected]>
AuthorDate: Thu Mar 16 17:48:24 2023 +0800
[bugfix](compaction) remove useless check #17804
cherry-pick #17804
---
be/src/olap/cumulative_compaction.cpp | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/be/src/olap/cumulative_compaction.cpp
b/be/src/olap/cumulative_compaction.cpp
index db9aaddf8a..54e4434fa0 100644
--- a/be/src/olap/cumulative_compaction.cpp
+++ b/be/src/olap/cumulative_compaction.cpp
@@ -117,7 +117,7 @@ Status CumulativeCompaction::pick_rowsets_to_compact() {
}
size_t compaction_score = 0;
- int transient_size =
_tablet->cumulative_compaction_policy()->pick_input_rowsets(
+ _tablet->cumulative_compaction_policy()->pick_input_rowsets(
_tablet.get(), candidate_rowsets,
config::max_cumulative_compaction_num_singleton_deltas,
config::min_cumulative_compaction_num_singleton_deltas,
&_input_rowsets,
@@ -151,9 +151,6 @@ Status CumulativeCompaction::pick_rowsets_to_compact() {
if (cumu_interval > interval_threshold && base_interval >
interval_threshold) {
// before increasing cumulative point, we should make sure all
rowsets are non-overlapping.
// if at least one rowset is overlapping, we should compact
them first.
- CHECK(candidate_rowsets.size() == transient_size)
- << "tablet: " << _tablet->full_name() << ", " <<
candidate_rowsets.size()
- << " vs. " << transient_size;
for (auto& rs : candidate_rowsets) {
if (rs->rowset_meta()->is_segments_overlapping()) {
_input_rowsets = candidate_rowsets;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
