aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAleksei Borzenkov <snaury@ydb.tech>2024-01-30 15:03:43 +0300
committerGitHub <noreply@github.com>2024-01-30 13:03:43 +0100
commit658eb362cb3806ee45cbdb944efb6719651af4b3 (patch)
tree22782fd978418d64ee7d209a73b5306350cda03f
parentedf8f5cfe32d680d8386706587157d0091320128 (diff)
downloadydb-658eb362cb3806ee45cbdb944efb6719651af4b3.tar.gz
Use EnableForceFollowers in some datashard tests (#1381)
-rw-r--r--ydb/core/tx/datashard/datashard_ut_followers.cpp3
-rw-r--r--ydb/core/tx/datashard/datashard_ut_volatile.cpp9
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);");