diff options
| author | alexnick <alexnick@yandex-team.ru> | 2022-02-22 12:17:14 +0300 |
|---|---|---|
| committer | alexnick <alexnick@yandex-team.ru> | 2022-02-22 12:17:14 +0300 |
| commit | e9a1653eaacf0eb8f2020035b5d83ef69cbe792c (patch) | |
| tree | 7a85267c408d270c0ee982de1fb2ccf9cafc5041 | |
| parent | fcb430c4801bd1440deaee6b5a2e3e028af7ab4b (diff) | |
| download | ydb-e9a1653eaacf0eb8f2020035b5d83ef69cbe792c.tar.gz | |
fix for test KIKIMR-14230
ref:83fe81bda445263daa309bfdecd20366450f7d1e
| -rw-r--r-- | ydb/services/datastreams/datastreams_ut.cpp | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/ydb/services/datastreams/datastreams_ut.cpp b/ydb/services/datastreams/datastreams_ut.cpp index 2ede2a2d05..396363e1e5 100644 --- a/ydb/services/datastreams/datastreams_ut.cpp +++ b/ydb/services/datastreams/datastreams_ut.cpp @@ -676,9 +676,6 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT(result.IsSuccess()); UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::SUCCESS); - UNIT_ASSERT(result.IsSuccess()); - UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::SUCCESS); - kikimr->GetRuntime()->SetLogPriority(NKikimrServices::PQ_READ_PROXY, NLog::EPriority::PRI_INFO); kikimr->GetRuntime()->SetLogPriority(NKikimrServices::PERSQUEUE, NLog::EPriority::PRI_INFO); @@ -737,7 +734,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { .RetryPolicy(NYdb::NPersQueue::IRetryPolicy::GetNoRetryPolicy()) .AppendTopics(NYdb::NPersQueue::TTopicReadSettings().Path(streamPath))); ui32 readCount = 0; - while (readCount < 14) { + while (readCount < 16) { auto event = session->GetEvent(true); if (auto* dataReceivedEvent = std::get_if<NYdb::NPersQueue::TReadSessionEvent::TDataReceivedEvent>(&*event)) { @@ -753,7 +750,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { break; } } - UNIT_ASSERT_VALUES_EQUAL(readCount, 14); + UNIT_ASSERT_VALUES_EQUAL(readCount, 16); } Y_UNIT_TEST(TestPutRecords) { |