diff --git a/txn/flusher.go b/txn/flusher.go index 3d1882d7f..5d1c1bdd8 100644 --- a/txn/flusher.go +++ b/txn/flusher.go @@ -759,7 +759,7 @@ func (f *flusher) checkpoint(t *transaction, revnos []int64) error { f.debugf("Ready to apply %s. Saving revnos %v: LOST RACE", t, debugRevnos) return f.reload(t) } - return nil + return err } func (f *flusher) apply(t *transaction, pull map[bson.ObjectId]*transaction) error {