aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoreivanov89 <eivanov89@ydb.tech>2023-01-09 21:29:26 +0300
committereivanov89 <eivanov89@ydb.tech>2023-01-09 21:29:26 +0300
commit71dae704b988f15eee2751c291c415263c9b35e3 (patch)
treec4d356e7cb8bb463af9030760233d1bdcd2db95d
parent18590c1c3b06ab6b03c4bcdc6dbc645bab1f6616 (diff)
downloadydb-71dae704b988f15eee2751c291c415263c9b35e3.tar.gz
properly stop ycsb kqp upsert actor and info collector
-rw-r--r--ydb/core/load_test/ycsb/kqp_upsert.cpp3
-rw-r--r--ydb/core/load_test/ycsb/test_load_actor.cpp4
2 files changed, 5 insertions, 2 deletions
diff --git a/ydb/core/load_test/ycsb/kqp_upsert.cpp b/ydb/core/load_test/ycsb/kqp_upsert.cpp
index 5fa970b116..ecfd3c28a0 100644
--- a/ydb/core/load_test/ycsb/kqp_upsert.cpp
+++ b/ydb/core/load_test/ycsb/kqp_upsert.cpp
@@ -398,8 +398,7 @@ private:
void HandlePoison(const TActorContext& ctx) {
LOG_DEBUG_S(ctx, NKikimrServices::DS_LOAD_TEST, "TKqpUpsertActorMultiSession# " << Tag
<< " tablet recieved PoisonPill, going to die");
- // TODO: stop subactors?
- Die(ctx);
+ Stop(ctx);
}
void StopWithError(const TActorContext& ctx, const TString& reason) {
diff --git a/ydb/core/load_test/ycsb/test_load_actor.cpp b/ydb/core/load_test/ycsb/test_load_actor.cpp
index d40c8c9415..1bc0d52491 100644
--- a/ydb/core/load_test/ycsb/test_load_actor.cpp
+++ b/ydb/core/load_test/ycsb/test_load_actor.cpp
@@ -552,6 +552,10 @@ public:
ctx.Send(actorId, new TEvents::TEvPoison());
}
+ if (HttpInfoCollector) {
+ ctx.Send(HttpInfoCollector, new TEvents::TEvPoison());
+ }
+
CloseSession(ctx);
Die(ctx);