diff --git a/ydb/core/mind/hive/hive_ut.cpp b/ydb/core/mind/hive/hive_ut.cpp index ef5a45498f05..84b6487d4b21 100644 --- a/ydb/core/mind/hive/hive_ut.cpp +++ b/ydb/core/mind/hive/hive_ut.cpp @@ -3392,6 +3392,8 @@ Y_UNIT_TEST_SUITE(THiveTest) { const ui64 testerTablet = MakeTabletID(false, 1); CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); + auto syncReassign = runtime.AddObserver([] (auto&& ev) { ev->Get()->Record.SetAsync(false); }); + TTabletTypes::EType tabletType = TTabletTypes::Dummy; TVector tablets; for (ui64 i = 0; i < NUM_TABLETS; ++i) { @@ -9075,6 +9077,11 @@ Y_UNIT_TEST_SUITE(TStorageBalanceTest) { OnBootTablet(info); return TTestActorRuntime::EEventAction::PROCESS; } + case TEvHive::EvReassignTablet: { + auto& record = ev->Get()->Record; + record.SetAsync(false); + return TTestActorRuntime::EEventAction::PROCESS; + } } return TTestActorRuntime::EEventAction::PROCESS; }; diff --git a/ydb/core/mind/hive/storage_balancer.cpp b/ydb/core/mind/hive/storage_balancer.cpp index 0687c7cad1a2..db9a75be88f3 100644 --- a/ydb/core/mind/hive/storage_balancer.cpp +++ b/ydb/core/mind/hive/storage_balancer.cpp @@ -177,6 +177,7 @@ class THiveStorageBalancer : public NActors::TActorBootstrapped(channel.TabletId); ev->Record.SetReassignReason(NKikimrHive::TEvReassignTablet::HIVE_REASSIGN_REASON_BALANCE); + ev->Record.SetAsync(true); } ev->Record.AddChannels(channel.ChannelId); }