diff --git a/be/src/common/config.h b/be/src/common/config.h index b074c85cbd..f868d78dc8 100644 --- a/be/src/common/config.h +++ b/be/src/common/config.h @@ -279,7 +279,7 @@ namespace config { // num_based policy, the original version of cumulative compaction, cumulative version compaction once. // size_based policy, a optimization version of cumulative compaction, targeting the use cases requiring // lower write amplification, trading off read amplification and space amplification. - CONF_String(cumulative_compaction_policy, "num_based"); + CONF_String(cumulative_compaction_policy, "size_based"); // In size_based policy, output rowset of cumulative compaction total disk size exceed this config size, // this rowset will be given to base compaction, unit is m byte. diff --git a/be/src/olap/tablet.cpp b/be/src/olap/tablet.cpp index ea841642c0..df64de6b03 100644 --- a/be/src/olap/tablet.cpp +++ b/be/src/olap/tablet.cpp @@ -445,6 +445,13 @@ void Tablet::delete_expired_stale_rowset() { std::vector missed_versions; calc_missed_versions_unlocked(lastest_delta->end_version(), &missed_versions); + if (!missed_versions.empty()) { + LOG(WARNING) << "tablet:" << full_name() << ", missed version for version:" + << lastest_delta->end_version(); + _print_missed_versions(missed_versions); + return; + } + // do check consistent operation auto path_id_iter = path_id_vec.begin();