DM: fix checkpoints update and flush, refine relay log write and read (…

…#401)
pingcap · Jan 16, 2019 · e130de7 · e130de7
1 parent 617e956
commit e130de7
Show file tree

Hide file tree

Showing 4 changed files with 327 additions and 170 deletions.
diff --git a/pkg/streamer/file.go b/pkg/streamer/file.go
@@ -93,7 +93,6 @@ func parseBinlogFile(filename string) (*binlogFile, error) {
 	// chendahui: I found there will always be only one dot in the mysql binlog name.
 	parts := strings.Split(filename, baseSeqSeparator)
 	if len(parts) != 2 {
-		log.Warnf("[streamer] filename %s not valid", filename)
 		return nil, ErrInvalidBinlogFilename
 	}