parent
149f17477b
commit
5db1c84dfd
@ -180,7 +180,6 @@ func (this *EventsStreamer) StreamEvents(canStopStreaming func() bool) error {
|
|||||||
var successiveFailures int64
|
var successiveFailures int64
|
||||||
var lastAppliedRowsEventHint mysql.BinlogCoordinates
|
var lastAppliedRowsEventHint mysql.BinlogCoordinates
|
||||||
for {
|
for {
|
||||||
this.migrationContext.Log.Debugf("Am I gonna stop??, %v", canStopStreaming())
|
|
||||||
if canStopStreaming() {
|
if canStopStreaming() {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user