diff options
author | hcpp <hcpp@ydb.tech> | 2022-09-02 12:20:33 +0300 |
---|---|---|
committer | hcpp <hcpp@ydb.tech> | 2022-09-02 12:20:33 +0300 |
commit | 01f64c1ecd0d4ffa9e3a74478335f1745f26cc75 (patch) | |
tree | f6ead98b1ee142e437474dd5c8e367fa3f3b66d5 | |
parent | e1130ed45c01575975413fc4fa1099d974c8db23 (diff) | |
download | ydb-01f64c1ecd0d4ffa9e3a74478335f1745f26cc75.tar.gz |
ping spam has been fixed
-rw-r--r-- | ydb/core/yq/libs/actors/run_actor.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/ydb/core/yq/libs/actors/run_actor.cpp b/ydb/core/yq/libs/actors/run_actor.cpp index e2aeec37f4..953fda46e9 100644 --- a/ydb/core/yq/libs/actors/run_actor.cpp +++ b/ydb/core/yq/libs/actors/run_actor.cpp @@ -757,9 +757,11 @@ private: } void Handle(TEvDqStats::TPtr& ev) { - Fq::Private::PingTaskRequest request; - *request.mutable_transient_issues() = ev->Get()->Record.issues(); - Send(Pinger, new TEvents::TEvForwardPingRequest(request), 0); + if (ev->Get()->Record.issues_size()) { + Fq::Private::PingTaskRequest request; + *request.mutable_transient_issues() = ev->Get()->Record.issues(); + Send(Pinger, new TEvents::TEvForwardPingRequest(request), 0); + } } i32 UpdateResultIndices() { |