diff --git a/db/db_filesnapshot.cc b/db/db_filesnapshot.cc index c35d8e7961e519fc58d63ad23696ee8902624591..a442c68b2b4a27ef75675dfdd95b8ca068473ba8 100644 --- a/db/db_filesnapshot.cc +++ b/db/db_filesnapshot.cc @@ -69,6 +69,7 @@ Status DBImpl::EnableFileDeletions(bool force) { if (should_purge_files) { PurgeObsoleteFiles(job_context); } + job_context.Clean(); LogFlush(db_options_.info_log); return Status::OK(); } diff --git a/db/flush_job_test.cc b/db/flush_job_test.cc index 0fa5b4e5721fdb213bee4dd7a5efaee3426af34d..33d1abe861514cbb57cb5c8e0813d38b7078229a 100644 --- a/db/flush_job_test.cc +++ b/db/flush_job_test.cc @@ -85,6 +85,7 @@ TEST(FlushJobTest, Empty) { SequenceNumber(), &job_context, nullptr, nullptr, kNoCompression, nullptr); ASSERT_OK(flush_job.Run()); + job_context.Clean(); } TEST(FlushJobTest, NonEmpty) { @@ -113,6 +114,7 @@ TEST(FlushJobTest, NonEmpty) { ASSERT_OK(flush_job.Run()); mutex_.Unlock(); mock_table_factory_->AssertSingleFile(inserted_keys); + job_context.Clean(); } } // namespace rocksdb