aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEvgeniy Ivanov <i@eivanov.com>2022-04-25 19:21:36 +0300
committerEvgeniy Ivanov <i@eivanov.com>2022-04-25 19:21:36 +0300
commit66660065fc13ecc29c05a742be027789edc3c88e (patch)
treee465e96eca79f19b36a1488bbb1a0bb35e7ed713
parent5dcf87b80afd4dc0381ca32b2f8a8539b89b31b7 (diff)
downloadydb-66660065fc13ecc29c05a742be027789edc3c88e.tar.gz
KIKIMR-14646: fix previously broken test
ref:d169da513dd32e4a8ea69a2aff5c46250234eda3
-rw-r--r--ydb/core/tx/schemeshard/ut_ttl.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/ydb/core/tx/schemeshard/ut_ttl.cpp b/ydb/core/tx/schemeshard/ut_ttl.cpp
index cafa7bfcb32..970e7c4bb9e 100644
--- a/ydb/core/tx/schemeshard/ut_ttl.cpp
+++ b/ydb/core/tx/schemeshard/ut_ttl.cpp
@@ -830,7 +830,7 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
const auto sender = runtime.AllocateEdgeActor();
runtime.SendToPipe(TTestTxConfig::SchemeShard, sender, new TEvTablet::TEvGetCounters);
auto ev = runtime.GrabEdgeEvent<TEvTablet::TEvGetCountersResponse>(sender);
-
+
UNIT_ASSERT(ev);
return ev->Get()->Record;
}
@@ -899,7 +899,7 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
runtime.UpdateCurrentTime(TInstant::Now());
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 0);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 0}, {"inf", 0}});
// create
TestCreateTable(runtime, ++txId, "/MyRoot", R"(
@@ -917,17 +917,17 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
// just after create
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 0}, {"inf", 1}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 0}, {"inf", 1}});
// after erase
WaitForCondErase(runtime);
WaitForStats(runtime, 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 1}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 1}, {"1800", 0}, {"inf", 0}});
// after a little more time
runtime.AdvanceCurrentTime(TDuration::Minutes(20));
WaitForStats(runtime, 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 1}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 1}, {"inf", 0}});
// copy table
TestCopyTable(runtime, ++txId, "/MyRoot", "TTLEnabledTableCopy", "/MyRoot/TTLEnabledTable");
@@ -935,13 +935,13 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
// just after copy
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 2);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 2}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 2}, {"inf", 0}});
// after erase
runtime.AdvanceCurrentTime(TDuration::Hours(1));
WaitForCondErase(runtime);
WaitForStats(runtime, 2);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 2}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 2}, {"1800", 0}, {"inf", 0}});
// alter (disable ttl)
TestAlterTable(runtime, ++txId, "/MyRoot", R"(
@@ -955,7 +955,7 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
// just after alter
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 1}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 1}, {"1800", 0}, {"inf", 0}});
// drop
TestDropTable(runtime, ++txId, "/MyRoot", "TTLEnabledTableCopy");
@@ -963,7 +963,7 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
// just after drop
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 0);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 0}, {"inf", 0}});
// alter (enable ttl)
TestAlterTable(runtime, ++txId, "/MyRoot", R"(
@@ -978,12 +978,12 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
// just after alter
CheckSimpleCounter(runtime, "SchemeShard/TTLEnabledTables", 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 1}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 1}, {"1800", 0}, {"inf", 0}});
// after a little more time
runtime.AdvanceCurrentTime(TDuration::Minutes(20));
WaitForStats(runtime, 1);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 0}, {"900", 1}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 0}, {"1800", 1}, {"inf", 0}});
// split
TestSplitTable(runtime, ++txId, "/MyRoot/TTLEnabledTable", Sprintf(R"(
@@ -1000,7 +1000,7 @@ Y_UNIT_TEST_SUITE(TSchemeShardTTLTests) {
runtime.AdvanceCurrentTime(TDuration::Hours(1));
WaitForCondErase(runtime);
WaitForStats(runtime, 2);
- CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"0", 2}, {"900", 0}, {"inf", 0}});
+ CheckPercentileCounter(runtime, "SchemeShard/NumShardsByTtlLag", {{"900", 2}, {"1800", 0}, {"inf", 0}});
}
}