Skip to content

Commit 34c57d8

Browse files
authored
Fix 24 1 (#4112)
1 parent ff2698f commit 34c57d8

File tree

1 file changed

+0
-21
lines changed

1 file changed

+0
-21
lines changed

ydb/core/persqueue/ut/sourceid_ut.cpp

-21
Original file line numberDiff line numberDiff line change
@@ -459,27 +459,6 @@ Y_UNIT_TEST_SUITE(TSourceIdTests) {
459459
UNIT_ASSERT(!emitter.CanEmit().Defined());
460460
}
461461
}
462-
463-
Y_UNIT_TEST(ExpensiveCleanup) {
464-
TSourceIdStorage storage;
465-
ui64 offset = 0;
466-
467-
// initial info w/o heartbeats
468-
for (ui32 i = 1; i <= 100000; ++i) {
469-
storage.RegisterSourceId(TestSourceId(i), MakeExplicitSourceIdInfo(++offset));
470-
}
471-
472-
NKikimrPQ::TPartitionConfig config;
473-
config.SetSourceIdLifetimeSeconds(TDuration::Hours(1).Seconds());
474-
475-
auto request = MakeHolder<TEvKeyValue::TEvRequest>();
476-
for (ui32 i = 0; i < 1000; ++i) {
477-
Cerr << "Iteration " << i << "\n";
478-
const auto dropped = storage.DropOldSourceIds(request.Get(), TInstant::Hours(2), 1'000'000, TPartitionId(TestPartition), config);
479-
UNIT_ASSERT_EQUAL(dropped, false);
480-
}
481-
482-
}
483462
} // TSourceIdTests
484463

485464
} // namespace NKikimr::NPQ

0 commit comments

Comments
 (0)