diff --git a/be/src/olap/wal_manager.cpp b/be/src/olap/wal_manager.cpp index f9209f73c74227a..3ab848282f7d285 100644 --- a/be/src/olap/wal_manager.cpp +++ b/be/src/olap/wal_manager.cpp @@ -368,7 +368,7 @@ Status WalManager::delete_wal(int64_t wal_id) { << _all_wal_disk_bytes->load(std::memory_order_relaxed); _wal_id_to_writer_map.erase(wal_id); } - if (_wal_id_to_writer_map.empty()) { + if (_wal_id_to_writer_map.empty() && !config::wait_relay_wal_finish) { CHECK_EQ(_all_wal_disk_bytes->load(std::memory_order_relaxed), 0); } auto it = _wal_path_map.find(wal_id);