ignore binlog from schema mysql (#210)

moiot · Sep 20, 2019 · 4e09412 · 4e09412
1 parent e910021
commit 4e09412
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/inputs/mysqlstream/binlog_tailer.go b/pkg/inputs/mysqlstream/binlog_tailer.go
@@ -264,6 +264,11 @@ func (tailer *BinlogTailer) Start() error {
 
 				schemaName, tableName := string(ev.Table.Schema), string(ev.Table.Table)
 
+				if schemaName == "mysql" {
+					log.Debugf("ignore change from mysql, table=%s", tableName)
+					continue
+				}
+
 				// dead signal is received from special internal table.
 				// it is only used for test purpose right now.
 				isDeadSignal := mysql_test.IsDeadSignal(schemaName, tableName)