log errors

Author: cameron-p-m

canal/canal.go

@@ -19,6 +19,7 @@ import (
 	"github.com/go-mysql-org/go-mysql/schema"
 	"github.com/pingcap/errors"
 	"github.com/pingcap/parser"
+	"github.com/siddontang/go-log/log"
 )
 
 // Canal can sync your MySQL data into everywhere, like Elasticsearch, Redis, etc...
@@ -221,12 +222,14 @@ func (c *Canal) run() error {
 		close(c.dumpDoneCh)
 
 		if err != nil {
+			log.Errorf("canal dump mysql err: %v", err)
 			return errors.Trace(err)
 		}
 	}
 
 	if err := c.runSyncBinlog(); err != nil {
 		if errors.Cause(err) != context.Canceled {
+			log.Errorf("canal start sync binlog err: %v", err)
 			return errors.Trace(err)
 		}
 	}
@@ -235,7 +238,7 @@ func (c *Canal) run() error {
 }
 
 func (c *Canal) Close() {
-	c.cfg.Logger.Infof("closing canal")
+	log.Infof("closing canal")
 	c.m.Lock()
 	defer c.m.Unlock()
 
@@ -349,6 +352,8 @@ func (c *Canal) GetTable(db string, table string) (*schema.Table, error) {
 			c.tableLock.Lock()
 			c.errorTablesGetTime[key] = time.Now()
 			c.tableLock.Unlock()
+			// log error and return ErrMissingTableMeta
+			log.Errorf("canal get table meta err: %v", errors.Trace(err))
 			return nil, schema.ErrMissingTableMeta
 		}
 		return nil, err