Skip to content

Commit

Permalink
10
Browse files Browse the repository at this point in the history
  • Loading branch information
Yukang-Lian committed Dec 10, 2024
1 parent d328575 commit abb7d02
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 5 deletions.
2 changes: 1 addition & 1 deletion be/src/cloud/cloud_cumulative_compaction.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ Status CloudCumulativeCompaction::prepare_compact() {
// plus 1 to skip the delete version.
// NOTICE: after that, the cumulative point may be larger than max version of this tablet, but it doesn't matter.
update_cumulative_point();
if (config::enable_sleep_between_delete_cumu_compaction) {
if (!config::enable_sleep_between_delete_cumu_compaction) {
st = Status::Error<CUMULATIVE_NO_SUITABLE_VERSION>(
"_last_delete_version.first not equal to -1");
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select --
-- !select1 --

-- !select2 --

Original file line number Diff line number Diff line change
Expand Up @@ -60,9 +60,9 @@ suite("test_cumu_compaction_with_delete") {
}
time_diff = System.currentTimeMillis() - now
logger.info("time_diff:" + time_diff)
assertTrue(time_diff<250*1000)
assertTrue(time_diff<200*1000)

qt_select """select * from ${tableName} order by user_id, value"""
qt_select1 """select * from ${tableName} order by user_id, value"""
} catch (Exception e){
logger.info(e.getMessage())
assertFalse(true)
Expand Down Expand Up @@ -111,7 +111,7 @@ suite("test_cumu_compaction_with_delete") {
logger.info("time_diff:" + time_diff)
assertTrue(time_diff>=250*1000)

qt_select """select * from ${tableName} order by user_id, value"""
qt_select2 """select * from ${tableName} order by user_id, value"""
} catch (Exception e){
logger.info(e.getMessage())
assertFalse(true)
Expand Down

0 comments on commit abb7d02

Please sign in to comment.