aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhcpp <hcpp@ydb.tech>2022-09-02 12:20:33 +0300
committerhcpp <hcpp@ydb.tech>2022-09-02 12:20:33 +0300
commit01f64c1ecd0d4ffa9e3a74478335f1745f26cc75 (patch)
treef6ead98b1ee142e437474dd5c8e367fa3f3b66d5
parente1130ed45c01575975413fc4fa1099d974c8db23 (diff)
downloadydb-01f64c1ecd0d4ffa9e3a74478335f1745f26cc75.tar.gz
ping spam has been fixed
-rw-r--r--ydb/core/yq/libs/actors/run_actor.cpp8
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() {