File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -386,7 +386,7 @@ func (c *Canal) CheckBinlogRowImage(image string) error {
386
386
// need to check MySQL binlog row image? full, minimal or noblob?
387
387
// now only log
388
388
if c .cfg .Flavor == mysql .MySQLFlavor {
389
- if res , err := c .Execute (`SHOW GLOBAL VARIABLES LIKE " binlog_row_image" ` ); err != nil {
389
+ if res , err := c .Execute (`SHOW GLOBAL VARIABLES LIKE ' binlog_row_image' ` ); err != nil {
390
390
return errors .Trace (err )
391
391
} else {
392
392
// MySQL has binlog row image from 5.6, so older will return empty
@@ -401,7 +401,7 @@ func (c *Canal) CheckBinlogRowImage(image string) error {
401
401
}
402
402
403
403
func (c * Canal ) checkBinlogRowFormat () error {
404
- res , err := c .Execute (`SHOW GLOBAL VARIABLES LIKE " binlog_format" ;` )
404
+ res , err := c .Execute (`SHOW GLOBAL VARIABLES LIKE ' binlog_format' ;` )
405
405
if err != nil {
406
406
return errors .Trace (err )
407
407
} else if f , _ := res .GetString (0 , 1 ); f != "ROW" {
You can’t perform that action at this time.
0 commit comments