diff --git a/src/v/cluster/data_migration_backend.cc b/src/v/cluster/data_migration_backend.cc index a412311b9ab7f..f40b003461e70 100644 --- a/src/v/cluster/data_migration_backend.cc +++ b/src/v/cluster/data_migration_backend.cc @@ -15,6 +15,7 @@ #include "cloud_storage/topic_mount_handler.h" #include "cluster/partition_leaders_table.h" #include "config/node_config.h" +#include "container/printable_range.h" #include "data_migration_frontend.h" #include "data_migration_types.h" #include "data_migration_worker.h" @@ -193,6 +194,7 @@ ss::future<> backend::loop_once() { } ss::future<> backend::work_once() { + vlog(dm_log.info, "begin backend work cycle"); // process pending deltas auto unprocessed_deltas = std::move(_unprocessed_deltas); for (auto&& delta : unprocessed_deltas) { @@ -307,6 +309,7 @@ ss::future<> backend::work_once() { } else { _timer.rearm(next_tick); } + vlog(dm_log.info, "end backend work cycle"); } void backend::wakeup() { _sem.signal(1 - _sem.available_units()); } @@ -762,6 +765,12 @@ void backend::to_advance_if_done( ar_it->second = advance_info(sought_state); } _migration_states.erase(it); + } else { + vlog( + dm_log.trace, + "outstanding topics for migration {}: {}", + it->first, + printable_range(rs.outstanding_topics | std::views::keys)); } } diff --git a/src/v/cluster/data_migration_frontend.cc b/src/v/cluster/data_migration_frontend.cc index 276313304d57f..65d2d437b2834 100644 --- a/src/v/cluster/data_migration_frontend.cc +++ b/src/v/cluster/data_migration_frontend.cc @@ -366,6 +366,7 @@ ss::future frontend::do_remove_migration(id id) { validate_migration_shard(); auto ec = co_await insert_barrier(); if (ec) { + vlog(dm_log.warn, "failed waiting for barrier: {}", ec); co_return ec; } /** @@ -373,6 +374,7 @@ ss::future frontend::do_remove_migration(id id) { */ auto migration = _table.get_migration(id); if (!migration) { + vlog(dm_log.warn, "migration {} id not found", id); co_return errc::data_migration_not_exists; } @@ -383,8 +385,10 @@ ss::future frontend::do_remove_migration(id id) { _operation_timeout + model::timeout_clock::now()); if (ec) { + vlog(dm_log.warn, "failed to send remove_data_migration_cmd: {}", ec); co_return ec; } + vlog(dm_log.debug, "successfully sent migration {} delete request", id); co_return errc::success; } diff --git a/src/v/cluster/topic_table.cc b/src/v/cluster/topic_table.cc index 88859587dcdb9..6dc95dfc70a73 100644 --- a/src/v/cluster/topic_table.cc +++ b/src/v/cluster/topic_table.cc @@ -205,6 +205,11 @@ ss::future topic_table::apply(create_partition_cmd cmd, model::offset offset) { auto const migration_state = _migrated_resources.get_topic_state( cmd.value.cfg.tp_ns); + vlog( + clusterlog.trace, + "attempting to create a partition in {}, migration state = {}", + cmd.value.cfg.tp_ns, + migration_state); if ( migration_state != data_migrations::migrated_resource_state::non_restricted) {