fix(input.mysql): no fatal when columns and data mismatch (#197)

moiot · Aug 21, 2019 · 886b6bd · 886b6bd
1 parent c187b24
commit 886b6bd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/inputs/mysqlstream/msg.go b/pkg/inputs/mysqlstream/msg.go
@@ -294,7 +294,7 @@ func NewDeleteMsgs(
 
 	for rowIndex, row := range ev.Rows {
 		if len(row) != len(columns) {
-			return nil, errors.Errorf("delete %s.%s columns and data mismatch in length: %d vs %d",
+			log.Warnf("delete %s.%s columns and data mismatch in length: %d vs %d",
 				tableDef.Schema, tableDef.Name, len(columns), len(row))
 		}
 		msg := core.Msg{