Skip to content

Commit 243a319

Browse files
authored
Filled DatabaseName in LoadTest while sending TEvNavigate events (#26109)
1 parent c39207e commit 243a319

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

ydb/core/load_test/ycsb/kqp_select.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -329,6 +329,7 @@ class TKqpSelectActorMultiSession : public TActorBootstrapped<TKqpSelectActorMul
329329
void DescribePath(const TActorContext& ctx) {
330330
TString path = Target.GetWorkingDir() + "/" + Target.GetTableName();
331331
auto request = std::make_unique<TEvTxUserProxy::TEvNavigate>();
332+
request->Record.SetDatabaseName(Target.GetWorkingDir());
332333
request->Record.MutableDescribePath()->SetPath(path);
333334
ctx.Send(MakeTxProxyID(), request.release());
334335
}

ydb/core/load_test/ycsb/test_load_actor.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,7 @@ class TLoad : public TActorBootstrapped<TLoad> {
270270
TString path = setup.GetWorkingDir() + "/" + setup.GetTableName();
271271

272272
auto request = std::make_unique<TEvTxUserProxy::TEvNavigate>();
273+
request->Record.SetDatabaseName(Request.GetTableSetup().GetWorkingDir());
273274
request->Record.MutableDescribePath()->SetPath(path);
274275

275276
ctx.Send(MakeTxProxyID(), request.release());

ydb/core/load_test/ycsb/test_load_read_iterator.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -359,6 +359,7 @@ class TReadIteratorLoadScenario : public TActorBootstrapped<TReadIteratorLoadSce
359359
void DescribePath(const TActorContext& ctx) {
360360
TString path = Target.GetWorkingDir() + "/" + Target.GetTableName();
361361
auto request = std::make_unique<TEvTxUserProxy::TEvNavigate>();
362+
request->Record.SetDatabaseName(Target.GetWorkingDir());
362363
request->Record.MutableDescribePath()->SetPath(path);
363364
ctx.Send(MakeTxProxyID(), request.release());
364365
}

0 commit comments

Comments
 (0)