YQ-3900 Fix ScheduleHeartbeat() if already connected (#11888)

ydb-platform · Nov 22, 2024 · fed0239 · fed0239
1 parent f5beef5
commit fed0239
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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) {