diff options
| -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) { |