We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59fd18d commit 11d66d8Copy full SHA for 11d66d8
go/logic/streamer.go
@@ -193,7 +193,7 @@ func (this *EventsStreamer) StreamEvents(canStopStreaming func() bool) error {
193
} else {
194
successiveFailures = 0
195
}
196
- if successiveFailures > this.migrationContext.MaxRetries() {
+ if successiveFailures >= this.migrationContext.MaxRetries() {
197
return fmt.Errorf("%d successive failures in streamer reconnect at coordinates %+v", successiveFailures, this.GetReconnectBinlogCoordinates())
198
199
0 commit comments