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

…#401)
pingcap · Nov 2, 2018 · aa3925e · aa3925e
1 parent 220aafd
commit aa3925e
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
 	}