diff --git a/ydb/core/tx/datashard/datashard_ut_followers.cpp b/ydb/core/tx/datashard/datashard_ut_followers.cpp index 6218a4967d08..57f6b39f1ffc 100644 --- a/ydb/core/tx/datashard/datashard_ut_followers.cpp +++ b/ydb/core/tx/datashard/datashard_ut_followers.cpp @@ -16,7 +16,8 @@ Y_UNIT_TEST_SUITE(DataShardFollowers) { TPortManager pm; TServerSettings serverSettings(pm.GetPort(2134)); serverSettings.SetDomainName("Root") - .SetUseRealThreads(false); + .SetUseRealThreads(false) + .SetEnableForceFollowers(true); Tests::TServer::TPtr server = new TServer(serverSettings); auto &runtime = *server->GetRuntime(); diff --git a/ydb/core/tx/datashard/datashard_ut_volatile.cpp b/ydb/core/tx/datashard/datashard_ut_volatile.cpp index 8ae953f62914..efc134ed160e 100644 --- a/ydb/core/tx/datashard/datashard_ut_volatile.cpp +++ b/ydb/core/tx/datashard/datashard_ut_volatile.cpp @@ -1998,6 +1998,7 @@ Y_UNIT_TEST_SUITE(DataShardVolatile) { serverSettings.SetDomainName("Root") .SetNodeCount(1) .SetUseRealThreads(false) + .SetEnableForceFollowers(true) .SetEnableDataShardVolatileTransactions(true); Tests::TServer::TPtr server = new TServer(serverSettings); @@ -2017,14 +2018,6 @@ Y_UNIT_TEST_SUITE(DataShardVolatile) { CreateShardedTable(server, sender, "/Root", "table-1", opts); CreateShardedTable(server, sender, "/Root", "table-2", opts); - runtime.SimulateSleep(TDuration::Seconds(1)); - for (ui64 shard : GetTableShards(server, sender, "/Root/table-1")) { - InvalidateTabletResolverCache(runtime, shard); - } - for (ui64 shard : GetTableShards(server, sender, "/Root/table-2")) { - InvalidateTabletResolverCache(runtime, shard); - } - ExecSQL(server, sender, "UPSERT INTO `/Root/table-1` (key, value) VALUES (1, 1);"); ExecSQL(server, sender, "UPSERT INTO `/Root/table-2` (key, value) VALUES (2, 2);");