diff options
| -rw-r--r-- | src/mongo/db/timeseries/bucket_catalog.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/db/timeseries/bucket_catalog.cpp b/src/mongo/db/timeseries/bucket_catalog.cpp index ecbd9dd888b..7035cf36beb 100644 --- a/src/mongo/db/timeseries/bucket_catalog.cpp +++ b/src/mongo/db/timeseries/bucket_catalog.cpp @@ -285,8 +285,13 @@ void BucketCatalog::finish(std::shared_ptr<WriteBatch> batch, const CommitInfo& void BucketCatalog::abort(std::shared_ptr<WriteBatch> batch) { invariant(batch); - invariant(!batch->finished()); invariant(batch->_commitRights.load()); + + if (batch->finished()) { + invariant(batch->getResult().getStatus() == ErrorCodes::TimeseriesBucketCleared); + return; + } + Bucket* bucket = batch->bucket(); // Before we access the bucket, make sure it's still there. |