diff options
| author | Aleksei Borzenkov <snaury@ydb.tech> | 2024-01-30 15:03:43 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-01-30 13:03:43 +0100 |
| commit | 658eb362cb3806ee45cbdb944efb6719651af4b3 (patch) | |
| tree | 22782fd978418d64ee7d209a73b5306350cda03f | |
| parent | edf8f5cfe32d680d8386706587157d0091320128 (diff) | |
| download | ydb-658eb362cb3806ee45cbdb944efb6719651af4b3.tar.gz | |
Use EnableForceFollowers in some datashard tests (#1381)
| -rw-r--r-- | ydb/core/tx/datashard/datashard_ut_followers.cpp | 3 | ||||
| -rw-r--r-- | ydb/core/tx/datashard/datashard_ut_volatile.cpp | 9 |
2 files changed, 3 insertions, 9 deletions
diff --git a/ydb/core/tx/datashard/datashard_ut_followers.cpp b/ydb/core/tx/datashard/datashard_ut_followers.cpp index 6218a4967d..57f6b39f1f 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 8ae953f629..efc134ed16 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);"); |