octoleo/gh-ost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add debug info

Browse Source
This commit is contained in:
p0ny 2022-06-27 18:01:31 +08:00
parent 460fce5fbd
commit 149f17477b
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
go/logic/streamer.go
View File

@ -180,6 +180,7 @@ func (this *EventsStreamer) StreamEvents(canStopStreaming func() bool) error {
var successiveFailures int64
var lastAppliedRowsEventHint mysql.BinlogCoordinates
for {
this.migrationContext.Log.Debugf("Am I gonna stop??, %v", canStopStreaming())
if canStopStreaming() {
return nil
}