#1609 Refine Compact function

Signed-off-by: groot <yihua.mo@zilliz.com>
pull/1610/head
groot 2020-03-10 19:56:06 +08:00
parent 8872054603
commit 120ea4d0e3
1 changed files with 1 additions and 2 deletions

View File

@ -723,12 +723,11 @@ DBImpl::Compact(const std::string& table_id) {
ENGINE_LOG_DEBUG << "Updating meta after compaction...";
status = meta_ptr_->UpdateTableFiles(files_to_update);
OngoingFileChecker::GetInstance().UnmarkOngoingFile(file);
if (!status.ok()) {
compact_status = status;
break; // meta error, could not go on
}
OngoingFileChecker::GetInstance().UnmarkOngoingFile(file);
}
OngoingFileChecker::GetInstance().UnmarkOngoingFiles(files_to_compact);