diff options
| author | mokhotskii <mokhotskii@ydb.tech> | 2023-01-16 11:33:10 +0300 |
|---|---|---|
| committer | mokhotskii <mokhotskii@ydb.tech> | 2023-01-16 11:33:10 +0300 |
| commit | 36960b67dc27bff69f8597c6f9209a372a3ef02f (patch) | |
| tree | f5290f6b5779c85579629c425edb22a3c163c5ee | |
| parent | 5d95129522938de27ca81c462bcb57c438e43901 (diff) | |
| download | ydb-36960b67dc27bff69f8597c6f9209a372a3ef02f.tar.gz | |
Backport changes from release branch
For some reason changes were made only in release branch: https://a.yandex-team.ru/review/2814147/files/5
| -rw-r--r-- | ydb/services/datastreams/datastreams_ut.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/services/datastreams/datastreams_ut.cpp b/ydb/services/datastreams/datastreams_ut.cpp index 362e317e43d..505d239d8c7 100644 --- a/ydb/services/datastreams/datastreams_ut.cpp +++ b/ydb/services/datastreams/datastreams_ut.cpp @@ -437,7 +437,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { TInsecureDatastreamsTestServer testServer; const TString streamName = TStringBuilder() << "stream_" << Y_UNIT_TEST_NAME; const ui64 storageMb = 55_GB / 1_MB; - const ui32 shardCount = 5; + const ui32 shardCount = 2; { auto result = testServer.DataStreamsClient->CreateStream(streamName, NYDS_V1::TCreateStreamSettings().ShardCount(shardCount) @@ -489,7 +489,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { storageMb); }); - UNIT_ASSERT_VALUES_EQUAL(storageSchemaFound, 20); + UNIT_ASSERT_VALUES_EQUAL(storageSchemaFound, 8); auto throughputSchemaFound = CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName, @@ -524,7 +524,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL(usage.find("unit")->second.GetString(), "second"); }); - UNIT_ASSERT_VALUES_EQUAL(throughputSchemaFound, 20); + UNIT_ASSERT_VALUES_EQUAL(throughputSchemaFound, 8); auto putUnitsSchemaFound = CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName, "yds.events.puts.v1", @@ -551,7 +551,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL(usage.find("unit")->second.GetString(), "put_events"); }); - UNIT_ASSERT_VALUES_EQUAL(putUnitsSchemaFound, 20); + UNIT_ASSERT_VALUES_EQUAL(putUnitsSchemaFound, 8); NYdb::NPersQueue::TPersQueueClient pqClient(*testServer.Driver); { |