Skip to content

Commit 73c2345

Browse files
GazizonokiGazizonoki
authored
[C++ SDK] Refactor topic tests (part 3) (#19925)
1 parent 649f770 commit 73c2345

38 files changed

+3717
-3329
lines changed

‎ydb/core/persqueue/ut/ut_with_sdk/autoscaling_ut.cpp

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
175175

176176
void PartitionSplit_oldSDK(SdkVersion sdk) {
177177
TTopicSdkTestSetup setup = CreateSetup();
178-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
178+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
179179

180180
TTopicClient client = setup.MakeClient();
181181

@@ -228,7 +228,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
228228

229229
Y_UNIT_TEST(PartitionSplit_AutoscaleAwareSDK) {
230230
TTopicSdkTestSetup setup = CreateSetup();
231-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
231+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
232232

233233
TTopicClient client = setup.MakeClient();
234234

@@ -273,7 +273,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
273273

274274
void PartitionSplit_PreferedPartition(SdkVersion sdk, bool autoscaleAwareSDK) {
275275
TTopicSdkTestSetup setup = CreateSetup();
276-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
276+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
277277

278278
TTopicClient client = setup.MakeClient();
279279

@@ -354,7 +354,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
354354

355355
void PartitionMerge_PreferedPartition(SdkVersion sdk, bool autoscaleAwareSDK) {
356356
TTopicSdkTestSetup setup = CreateSetup();
357-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 2, 100);
357+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 2, 100);
358358

359359
TTopicClient client = setup.MakeClient();
360360

@@ -426,7 +426,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
426426

427427
void PartitionSplit_ReadEmptyPartitions(SdkVersion sdk, bool autoscaleAwareSDK) {
428428
TTopicSdkTestSetup setup = CreateSetup();
429-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
429+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
430430

431431
TTopicClient client = setup.MakeClient();
432432
auto readSession = CreateTestReadSession({ .Name="Session-0", .Setup=setup, .Sdk = sdk, .AutoPartitioningSupport = autoscaleAwareSDK });
@@ -455,7 +455,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
455455

456456
void PartitionSplit_ReadNotEmptyPartitions(SdkVersion sdk) {
457457
TTopicSdkTestSetup setup = CreateSetup();
458-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
458+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
459459

460460
TTopicClient client = setup.MakeClient();
461461
auto readSession = CreateTestReadSession({ .Name="Session-0", .Setup=setup, .Sdk = sdk, .AutoCommit = false, .AutoPartitioningSupport = false });
@@ -490,7 +490,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
490490

491491
Y_UNIT_TEST(PartitionSplit_ReadNotEmptyPartitions_AutoscaleAwareSDK) {
492492
TTopicSdkTestSetup setup = CreateSetup();
493-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
493+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
494494

495495
TTopicClient client = setup.MakeClient();
496496
auto readSession = CreateTestReadSession({ .Name="Session-0", .Setup=setup, .Sdk = SdkVersion::Topic, .AutoCommit = false, .AutoPartitioningSupport = true });
@@ -511,7 +511,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
511511

512512
void PartitionSplit_ManySession(SdkVersion sdk) {
513513
TTopicSdkTestSetup setup = CreateSetup();
514-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
514+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
515515

516516
TTopicClient client = setup.MakeClient();
517517

@@ -551,7 +551,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
551551

552552
Y_UNIT_TEST(PartitionSplit_ManySession_AutoscaleAwareSDK) {
553553
TTopicSdkTestSetup setup = CreateSetup();
554-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
554+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
555555

556556
TTopicClient client = setup.MakeClient();
557557

@@ -596,7 +596,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
596596

597597
Y_UNIT_TEST(PartitionSplit_ManySession_existed_AutoscaleAwareSDK) {
598598
TTopicSdkTestSetup setup = CreateSetup();
599-
setup.CreateTopicWithAutoscale(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1, 100);
599+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
600600

601601
TTopicClient client = setup.MakeClient();
602602

@@ -860,8 +860,8 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
860860

861861
auto msg = TString(1_MB, 'a');
862862

863-
auto writeSession_1 = CreateWriteSession(client, "producer-1", 0, std::string{TEST_TOPIC}, false);
864-
auto writeSession_2 = CreateWriteSession(client, "producer-2", 0, std::string{TEST_TOPIC}, false);
863+
auto writeSession_1 = CreateWriteSession(client, "producer-1", 0, TString{TEST_TOPIC}, false);
864+
auto writeSession_2 = CreateWriteSession(client, "producer-2", 0, TString{TEST_TOPIC}, false);
865865

866866
{
867867
UNIT_ASSERT(writeSession_1->Write(Msg(msg, 1)));
@@ -881,8 +881,8 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
881881
UNIT_ASSERT_EQUAL(describe.GetTopicDescription().GetPartitions().size(), 3);
882882
}
883883

884-
auto writeSession2_1 = CreateWriteSession(client, "producer-1", 1, std::string{TEST_TOPIC}, false);
885-
auto writeSession2_2 = CreateWriteSession(client, "producer-2", 1, std::string{TEST_TOPIC}, false);
884+
auto writeSession2_1 = CreateWriteSession(client, "producer-1", 1, TString{TEST_TOPIC}, false);
885+
auto writeSession2_2 = CreateWriteSession(client, "producer-2", 1, TString{TEST_TOPIC}, false);
886886

887887
{
888888
UNIT_ASSERT(writeSession2_1->Write(Msg(msg, 7)));
@@ -922,8 +922,8 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
922922

923923
auto msg = TString(1_MB, 'a');
924924

925-
auto writeSession_1 = CreateWriteSession(client, "producer-1", 0, std::string{TEST_TOPIC}, false);
926-
auto writeSession_2 = CreateWriteSession(client, "producer-2", 0, std::string{TEST_TOPIC}, false);
925+
auto writeSession_1 = CreateWriteSession(client, "producer-1", 0, TString{TEST_TOPIC}, false);
926+
auto writeSession_2 = CreateWriteSession(client, "producer-2", 0, TString{TEST_TOPIC}, false);
927927

928928
{
929929
UNIT_ASSERT(writeSession_1->Write(Msg(msg, 1)));
@@ -943,8 +943,8 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
943943
UNIT_ASSERT_EQUAL(describe.GetTopicDescription().GetPartitions().size(), 3);
944944
}
945945

946-
auto writeSession2_1 = CreateWriteSession(client, "producer-1", 1, std::string{TEST_TOPIC}, false);
947-
auto writeSession2_2 = CreateWriteSession(client, "producer-2", 1, std::string{TEST_TOPIC}, false);
946+
auto writeSession2_1 = CreateWriteSession(client, "producer-1", 1, TString{TEST_TOPIC}, false);
947+
auto writeSession2_2 = CreateWriteSession(client, "producer-2", 1, TString{TEST_TOPIC}, false);
948948

949949
{
950950
UNIT_ASSERT(writeSession2_1->Write(Msg(msg, 7)));
@@ -1190,7 +1190,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
11901190

11911191
Y_UNIT_TEST(BalancingAfterSplit_sessionsWithPartition) {
11921192
TTopicSdkTestSetup setup = CreateSetup();
1193-
setup.CreateTopicWithAutoscale(TString{TEST_TOPIC}, TEST_CONSUMER, 1, 100);
1193+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 1, 100);
11941194

11951195
TTopicClient client = setup.MakeClient();
11961196

@@ -1230,7 +1230,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
12301230

12311231
Y_UNIT_TEST(ReBalancingAfterSplit_sessionsWithPartition) {
12321232
TTopicSdkTestSetup setup = CreateSetup();
1233-
setup.CreateTopicWithAutoscale(TString{TEST_TOPIC}, TEST_CONSUMER, 2, 100);
1233+
setup.CreateTopicWithAutoscale(TEST_TOPIC, TEST_CONSUMER, 2, 100);
12341234

12351235
TTopicClient client = setup.MakeClient();
12361236

‎ydb/core/persqueue/ut/ut_with_sdk/balancing_ut.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ Y_UNIT_TEST_SUITE(Balancing) {
2020

2121
void Simple(SdkVersion sdk) {
2222
TTopicSdkTestSetup setup = CreateSetup();
23-
setup.CreateTopic(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 10);
23+
setup.CreateTopic(TEST_TOPIC, TEST_CONSUMER, 10);
2424

2525
auto readSession0 = CreateTestReadSession({ .Name="Session-0", .Setup=setup, .Sdk = sdk });
2626
{
@@ -116,8 +116,8 @@ Y_UNIT_TEST_SUITE(Balancing) {
116116

117117
void ManyTopics(SdkVersion sdk) {
118118
TTopicSdkTestSetup setup = CreateSetup();
119-
setup.CreateTopic(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 10);
120-
setup.CreateTopic("other-test-topic", std::string{TEST_CONSUMER}, 10);
119+
setup.CreateTopic(TEST_TOPIC, TEST_CONSUMER, 10);
120+
setup.CreateTopic("other-test-topic", TEST_CONSUMER, 10);
121121

122122
TTopicClient client = setup.MakeClient();
123123

@@ -126,7 +126,7 @@ Y_UNIT_TEST_SUITE(Balancing) {
126126

127127
{
128128
auto p = readSession0->GetPartitionsA();
129-
UNIT_ASSERT_VALUES_EQUAL(10, p[std::string{TEST_TOPIC}].size());
129+
UNIT_ASSERT_VALUES_EQUAL(10, p[TString{TEST_TOPIC}].size());
130130
UNIT_ASSERT_VALUES_EQUAL(10, p["other-test-topic"].size());
131131
}
132132

@@ -135,12 +135,12 @@ Y_UNIT_TEST_SUITE(Balancing) {
135135

136136
{
137137
auto p = readSession0->GetPartitionsA();
138-
UNIT_ASSERT_VALUES_EQUAL(5, p[std::string{TEST_TOPIC}].size());
138+
UNIT_ASSERT_VALUES_EQUAL(5, p[TString{TEST_TOPIC}].size());
139139
UNIT_ASSERT_VALUES_EQUAL(5, p["other-test-topic"].size());
140140
}
141141
{
142142
auto p = readSession1->GetPartitionsA();
143-
UNIT_ASSERT_VALUES_EQUAL(5, p[std::string{TEST_TOPIC}].size());
143+
UNIT_ASSERT_VALUES_EQUAL(5, p[TString{TEST_TOPIC}].size());
144144
UNIT_ASSERT_VALUES_EQUAL(5, p["other-test-topic"].size());
145145
}
146146

‎ydb/core/persqueue/ut/ut_with_sdk/topic_ut.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,10 @@ Y_UNIT_TEST_SUITE(WithSDK) {
3232

3333
Y_UNIT_TEST(DescribeConsumer) {
3434
TTopicSdkTestSetup setup = CreateSetup();
35-
setup.CreateTopic(std::string{TEST_TOPIC}, std::string{TEST_CONSUMER}, 1);
35+
setup.CreateTopic(TEST_TOPIC, TEST_CONSUMER, 1);
3636

3737
auto describe = [&]() {
38-
return setup.DescribeConsumer(TString{TEST_TOPIC}, TString{TEST_CONSUMER});
38+
return setup.DescribeConsumer(TEST_TOPIC, TEST_CONSUMER);
3939
};
4040

4141
auto write = [&](size_t seqNo) {
@@ -96,7 +96,7 @@ Y_UNIT_TEST_SUITE(WithSDK) {
9696
UNIT_ASSERT_VALUES_EQUAL(1, c->GetLastReadOffset());
9797
}
9898

99-
UNIT_ASSERT(setup.Commit(TString{TEST_TOPIC}, TEST_CONSUMER, 0, 1).IsSuccess());
99+
UNIT_ASSERT(setup.Commit(TEST_TOPIC, TEST_CONSUMER, 0, 1).IsSuccess());
100100

101101
// Check describe for topic whis contains messages, has commited offset but hasn`t read (restart tablet for example)
102102
{

‎ydb/core/persqueue/ut/ut_with_sdk/ya.make

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ PEERDIR(
2020
ydb/core/persqueue/ut/common
2121
ydb/core/testlib/default
2222
ydb/public/sdk/cpp/src/client/persqueue_public/ut/ut_utils
23-
ydb/public/sdk/cpp/src/client/persqueue_public/ut/ut_utils
2423
ydb/public/sdk/cpp/src/client/topic/ut/ut_utils
2524

2625
ydb/core/tx/schemeshard/ut_helpers

‎ydb/public/sdk/cpp/src/client/federated_topic/ut/basic_usage_ut.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
#include <ydb/public/sdk/cpp/include/ydb-cpp-sdk/client/federated_topic/federated_topic.h>
22
#include <ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.h>
33

4-
#include <ydb/public/sdk/cpp/src/client/topic/ut/ut_utils/managed_executor.h>
4+
#include <ydb/public/sdk/cpp/tests/integration/topic/utils/managed_executor.h>
55

66
#include <ydb/public/sdk/cpp/src/client/persqueue_public/persqueue.h>
77

‎ydb/public/sdk/cpp/src/client/federated_topic/ut/ya.make

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@ PEERDIR(
2525

2626
ydb/public/sdk/cpp/src/client/federated_topic
2727
ydb/public/sdk/cpp/src/client/federated_topic/impl
28+
29+
ydb/public/sdk/cpp/tests/integration/topic/utils
2830
)
2931

3032
YQL_LAST_ABI_VERSION()

‎ydb/public/sdk/cpp/src/client/topic/ut/basic_usage_ut.cpp

Lines changed: 24 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,7 @@
1-
#include "ut_utils/managed_executor.h"
21
#include "ut_utils/topic_sdk_test_setup.h"
2+
3+
#include <ydb/public/sdk/cpp/tests/integration/topic/utils/managed_executor.h>
4+
35
#include <ydb/public/sdk/cpp/src/client/persqueue_public/ut/ut_utils/ut_utils.h>
46

57
#include <ydb/public/sdk/cpp/include/ydb-cpp-sdk/client/topic/client.h>
@@ -18,19 +20,19 @@
1820

1921
#include <util/stream/zlib.h>
2022

21-
#include <future>
2223

24+
using namespace std::chrono_literals;
2325

2426
static const bool EnableDirectRead = !std::string{std::getenv("PQ_EXPERIMENTAL_DIRECT_READ") ? std::getenv("PQ_EXPERIMENTAL_DIRECT_READ") : ""}.empty();
2527

2628

27-
namespace NYdb::NTopic::NTests {
29+
namespace NYdb::inline Dev::NTopic::NTests {
2830

29-
void WriteAndReadToEndWithRestarts(TReadSessionSettings readSettings, TWriteSessionSettings writeSettings, const std::string& message, ui32 count, TTopicSdkTestSetup& setup, TIntrusivePtr<TManagedExecutor> decompressor) {
31+
void WriteAndReadToEndWithRestarts(TReadSessionSettings readSettings, TWriteSessionSettings writeSettings, const std::string& message, std::uint32_t count, TTopicSdkTestSetup& setup, TIntrusivePtr<TManagedExecutor> decompressor) {
3032
auto client = setup.MakeClient();
3133
auto session = client.CreateSimpleBlockingWriteSession(writeSettings);
3234

33-
for (ui32 i = 1; i <= count; ++i) {
35+
for (std::uint32_t i = 1; i <= count; ++i) {
3436
bool res = session->Write(message);
3537
UNIT_ASSERT(res);
3638
}
@@ -44,7 +46,7 @@ void WriteAndReadToEndWithRestarts(TReadSessionSettings readSettings, TWriteSess
4446

4547
auto WaitTasks = [&](auto f, size_t c) {
4648
while (f() < c) {
47-
Sleep(TDuration::MilliSeconds(100));
49+
std::this_thread::sleep_for(100ms);
4850
};
4951
};
5052
auto WaitPlannedTasks = [&](auto e, size_t count) {
@@ -69,7 +71,7 @@ void WriteAndReadToEndWithRestarts(TReadSessionSettings readSettings, TWriteSess
6971
size_t completed = e->GetExecutedCount();
7072

7173
setup.GetServer().KillTopicPqrbTablet(setup.GetTopicPath());
72-
Sleep(TDuration::MilliSeconds(100));
74+
std::this_thread::sleep_for(100ms);
7375

7476
e->StartFuncs(tasks);
7577
WaitExecutedTasks(e, completed + n);
@@ -90,7 +92,7 @@ void WriteAndReadToEndWithRestarts(TReadSessionSettings readSettings, TWriteSess
9092

9193
ReadSession = topicClient.CreateReadSession(readSettings);
9294

93-
ui32 i = 0;
95+
std::uint32_t i = 0;
9496
while (AtomicGet(lastOffset) + 1 < count) {
9597
RunTasks(decompressor, {i++});
9698
}
@@ -109,7 +111,7 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
109111
auto decompressor = CreateThreadPoolManagedExecutor(1);
110112

111113
TReadSessionSettings readSettings;
112-
TTopicReadSettings topic = TEST_TOPIC;
114+
TTopicReadSettings topic = setup.GetTopicPath();
113115
topic.AppendPartitionIds(0);
114116
readSettings
115117
.WithoutConsumer()
@@ -121,13 +123,13 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
121123

122124
TWriteSessionSettings writeSettings;
123125
writeSettings
124-
.Path(TEST_TOPIC)
126+
.Path(setup.GetTopicPath())
125127
.MessageGroupId(TEST_MESSAGE_GROUP_ID)
126128
.Codec(NTopic::ECodec::RAW)
127129
.CompressionExecutor(compressor);
128130

129131

130-
ui32 count = 700;
132+
std::uint32_t count = 700;
131133
std::string message(2'000, 'x');
132134

133135
WriteAndReadToEndWithRestarts(readSettings, writeSettings, message, count, setup, decompressor);
@@ -140,21 +142,21 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
140142

141143
TReadSessionSettings readSettings;
142144
readSettings
143-
.ConsumerName(TEST_CONSUMER)
145+
.ConsumerName(setup.GetConsumerName())
144146
.MaxMemoryUsageBytes(1_MB)
145147
.DecompressionExecutor(decompressor)
146-
.AppendTopics(TEST_TOPIC)
148+
.AppendTopics(setup.GetTopicPath())
147149
// .DirectRead(EnableDirectRead)
148150
;
149151

150152
TWriteSessionSettings writeSettings;
151153
writeSettings
152-
.Path(TEST_TOPIC).MessageGroupId(TEST_MESSAGE_GROUP_ID)
153-
.Codec(NTopic::ECodec::RAW)
154+
.Path(setup.GetTopicPath()).MessageGroupId(TEST_MESSAGE_GROUP_ID)
155+
.Codec(ECodec::RAW)
154156
.CompressionExecutor(compressor);
155157

156158

157-
ui32 count = 700;
159+
std::uint32_t count = 700;
158160
std::string message(2'000, 'x');
159161

160162
WriteAndReadToEndWithRestarts(readSettings, writeSettings, message, count, setup, decompressor);
@@ -164,25 +166,25 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
164166

165167
TTopicSdkTestSetup setup(TEST_CASE_NAME);
166168

167-
NTopic::TWriteSessionSettings writeSettings;
169+
TWriteSessionSettings writeSettings;
168170
writeSettings.Path(setup.GetTopicPath()).MessageGroupId(TEST_MESSAGE_GROUP_ID);
169171
writeSettings.Path(setup.GetTopicPath()).ProducerId(TEST_MESSAGE_GROUP_ID);
170-
writeSettings.Codec(NTopic::ECodec::RAW);
171-
NTopic::IExecutor::TPtr executor = new NTopic::TSyncExecutor();
172+
writeSettings.Codec(ECodec::RAW);
173+
IExecutor::TPtr executor = new TSyncExecutor();
172174
writeSettings.CompressionExecutor(executor);
173175

174-
ui64 count = 100u;
176+
std::uint64_t count = 100u;
175177

176178
auto client = setup.MakeClient();
177179
auto session = client.CreateSimpleBlockingWriteSession(writeSettings);
178180

179-
TString messageBase = "message----";
181+
std::string messageBase = "message----";
180182

181183
for (auto i = 0u; i < count; i++) {
182184
auto res = session->Write(messageBase);
183185
UNIT_ASSERT(res);
184186
if (i % 10 == 0) {
185-
setup.GetServer().KillTopicPqTablets(setup.GetTopicPath());
187+
setup.GetServer().KillTopicPqTablets(setup.GetFullTopicPath());
186188
}
187189
}
188190
session->Close();

0 commit comments

Comments
 (0)