From 0fe9b2c3bbd57258c8220259aa480880b91e1319 Mon Sep 17 00:00:00 2001 From: bobhan1 Date: Wed, 8 Jan 2025 15:49:41 +0800 Subject: [PATCH] add force-trigger-cumu --- be/src/cloud/cloud_cumulative_compaction_policy.cpp | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/be/src/cloud/cloud_cumulative_compaction_policy.cpp b/be/src/cloud/cloud_cumulative_compaction_policy.cpp index 92a47fcc69f8d7..7ec21fa6798cb3 100644 --- a/be/src/cloud/cloud_cumulative_compaction_policy.cpp +++ b/be/src/cloud/cloud_cumulative_compaction_policy.cpp @@ -54,6 +54,16 @@ int64_t CloudSizeBasedCumulativeCompactionPolicy::pick_input_rowsets( const int64_t max_compaction_score, const int64_t min_compaction_score, std::vector* input_rowsets, Version* last_delete_version, size_t* compaction_score, bool allow_delete) { + if (tablet->tablet_id() == 1735811221642) { + for (const auto& rs : candidate_rowsets) { + int64_t start_ver = 27; + int64_t end_ver = 32; + if (start_ver <= rs->start_version() && rs->end_version() <= end_ver) { + input_rowsets->emplace_back(rs); + } + } + return input_rowsets->size(); + } size_t promotion_size = cloud_promotion_size(tablet); auto max_version = tablet->max_version().first; int transient_size = 0;