diff options
| author | Dmitry Kardymon <[email protected]> | 2024-11-22 23:55:59 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-11-22 23:55:59 +0300 |
| commit | fed023977807e8f2d350197cfadf0afe9b0b24cb (patch) | |
| tree | 235098403edec4df1c16f4dd2a93015e379e3321 | |
| parent | f5beef5e566eab65072c276a69a3465656c521d4 (diff) | |
YQ-3900 Fix ScheduleHeartbeat() if already connected (#11888)
| -rw-r--r-- | ydb/library/yql/dq/actors/common/retry_queue.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/library/yql/dq/actors/common/retry_queue.cpp b/ydb/library/yql/dq/actors/common/retry_queue.cpp index 2f232b6685d..64cd0a4eb6f 100644 --- a/ydb/library/yql/dq/actors/common/retry_queue.cpp +++ b/ydb/library/yql/dq/actors/common/retry_queue.cpp @@ -35,6 +35,9 @@ void TRetryEventsQueue::OnNewRecipientId(const NActors::TActorId& recipientId, b ReceivedEventsSeqNos.clear(); Connected = connected; RetryState = Nothing(); + if (Connected) { + ScheduleHeartbeat(); + } } void TRetryEventsQueue::HandleNodeDisconnected(ui32 nodeId) { |