diff --git a/replica/database.cc b/replica/database.cc index 4edc8a0974..9639e59714 100644 --- a/replica/database.cc +++ b/replica/database.cc @@ -2793,6 +2793,7 @@ future<> database::flush_all_tables() { }); _all_tables_flushed_at = db_clock::now(); co_await _commitlog->wait_for_pending_deletes(); + dblog.info("Forcing new commitlog segment and flushing all tables complete"); } future database::get_all_tables_flushed_at(sharded& sharded_db) { diff --git a/test/cluster/test_major_compaction.py b/test/cluster/test_major_compaction.py index 53c300be31..5ccbec163d 100644 --- a/test/cluster/test_major_compaction.py +++ b/test/cluster/test_major_compaction.py @@ -131,7 +131,7 @@ async def test_major_compaction_flush_all_tables(manager: ManagerClient, compact await manager.api.keyspace_compaction(server.ip_addr, ks, cf) flush_log = await log.grep("Forcing new commitlog segment and flushing all tables", from_mark=mark) - assert len(flush_log) == (1 if expect_all_table_flush else 0) + assert len(flush_log) == (2 if expect_all_table_flush else 0) # all tables should be flushed the first time unless compaction_flush_all_tables_before_major_seconds == 0 await check_all_table_flush_in_major_compaction(compaction_flush_all_tables_before_major_seconds != 0)