diff --git a/src/v/cluster/partition_manager.cc b/src/v/cluster/partition_manager.cc index 5dbd8d58e2e1..e9e5b0802373 100644 --- a/src/v/cluster/partition_manager.cc +++ b/src/v/cluster/partition_manager.cc @@ -255,6 +255,7 @@ partition_manager::remove(const model::ntp& ntp, partition_removal_mode mode) { .then([this, ntp] { _unmanage_watchers.notify(ntp, ntp.tp.partition); }) .then([partition] { return partition->stop(); }) .then([partition] { return partition->remove_persistent_state(); }) + .then([this, ntp] { return _storage.log_mgr().remove(ntp); }) .then([partition, mode] { if (mode == partition_removal_mode::global) { return partition->remove_remote_persistent_state(); @@ -262,7 +263,6 @@ partition_manager::remove(const model::ntp& ntp, partition_removal_mode mode) { return ss::now(); } }) - .then([this, ntp] { return _storage.log_mgr().remove(ntp); }) .finally([partition] {}); // in the end remove partition }