fix pos save logic

Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>

canal/sync.go

@@ -149,6 +149,8 @@ func (c *Canal) runSyncBinlog() error {
 			for _, stmt := range stmts {
 				nodes := parseDDLStmt(stmt)
 				if len(nodes) > 0 {
+					posInfo.SavePos = true
+					posInfo.Force = true
 					err := c.handleDDLEvent(ev, e, nodes, posInfo)
 					if err != nil {
 						c.cfg.Logger.Errorf("handle ddl event err %v", err)
@@ -233,6 +235,7 @@ func (c *Canal) updateTable(header *replication.EventHeader, db, table string) (
 	}
 	return
 }
+
 func (c *Canal) updateReplicationDelay(ev *replication.BinlogEvent) {
 	var newDelay uint32
 	now := uint32(time.Now().Unix())
@@ -356,8 +359,6 @@ func (c *Canal) handleDDLEvent(ev *replication.BinlogEvent, e *replication.Query
 		}
 	}
 	if len(nodes) > 0 {
-		pos.SavePos = true
-		pos.Force = true
 		// Now we only handle Table Changed DDL, maybe we will support more later.
 		if err := c.eventHandler.OnDDL(ev.Header, pos.Position, e); err != nil {
 			return errors.Trace(err)