diff --git a/src/v/cluster/controller_backend.cc b/src/v/cluster/controller_backend.cc index 5511f416ab27c..45e0414d715c8 100644 --- a/src/v/cluster/controller_backend.cc +++ b/src/v/cluster/controller_backend.cc @@ -505,7 +505,7 @@ ss::future<> controller_backend::reconcile_ntp(deltas_t& deltas) { stop = true; continue; } - vlog(clusterlog.info, "partition operation {} finished", *it); + vlog(clusterlog.debug, "partition operation {} finished", *it); } catch (ss::gate_closed_exception const&) { vlog( clusterlog.debug, diff --git a/src/v/cluster/partition_manager.cc b/src/v/cluster/partition_manager.cc index d68ca729f0abf..0e00701dd4924 100644 --- a/src/v/cluster/partition_manager.cc +++ b/src/v/cluster/partition_manager.cc @@ -106,7 +106,7 @@ ss::future partition_manager::manage( } storage::log log = co_await _storage.log_mgr().manage(std::move(ntp_cfg)); vlog( - clusterlog.info, + clusterlog.debug, "Log created manage completed, ntp: {}, rev: {}, {} " "segments, {} bytes", log.config().ntp(), diff --git a/src/v/cluster/topics_frontend.cc b/src/v/cluster/topics_frontend.cc index 04fdaeaa74c01..4adfae69cf42d 100644 --- a/src/v/cluster/topics_frontend.cc +++ b/src/v/cluster/topics_frontend.cc @@ -480,6 +480,8 @@ ss::future topics_frontend::replicate_create_topic( ss::future> topics_frontend::delete_topics( std::vector topics, model::timeout_clock::time_point timeout) { + vlog(clusterlog.info, "Delete topics {}", topics); + std::vector> futures; futures.reserve(topics.size()); diff --git a/src/v/raft/state_machine.cc b/src/v/raft/state_machine.cc index 68856333e97b4..63b34dbdec80a 100644 --- a/src/v/raft/state_machine.cc +++ b/src/v/raft/state_machine.cc @@ -26,7 +26,7 @@ state_machine::state_machine( , _bootstrap_last_applied(_raft->read_last_applied()) {} ss::future<> state_machine::start() { - vlog(_log.info, "Starting state machine for ntp={}", _raft->ntp()); + vlog(_log.debug, "Starting state machine for ntp={}", _raft->ntp()); ssx::spawn_with_gate(_gate, [this] { return ss::do_until( [this] { return _gate.is_closed(); }, [this] { return apply(); }); @@ -118,11 +118,11 @@ ss::future<> state_machine::apply() { f = handle_eviction(); } return f.then([this] { - // build a reader for log range [_next, +inf). - storage::log_reader_config config( - _next, model::model_limits::max(), _io_prio); - return _raft->make_reader(config); - }); + // build a reader for log range [_next, +inf). + storage::log_reader_config config( + _next, model::model_limits::max(), _io_prio); + return _raft->make_reader(config); + }; }) .then([this](model::record_batch_reader reader) { // apply each batch to the state machine @@ -134,6 +134,9 @@ ss::future<> state_machine::apply() { } }); }) + .handle_exception_type([](const raft::offset_monitor::wait_aborted&) { + // Ignore, normnal during partition removal + }) .handle_exception([this](const std::exception_ptr& e) { vlog( _log.info, "State machine for ntp={} handles {}", _raft->ntp(), e);