Signed-off-by: Nitin Shatma <nitin.sharma@airbnb.com>
This commit is contained in:
Nitin Shatma 2019-09-23 18:53:21 -07:00
Родитель db326ae748
Коммит 4c8fd6d6c1
1 изменённых файлов: 1 добавлений и 10 удалений

Просмотреть файл

@ -345,18 +345,9 @@ func (vs *vstreamer) parseEvent(ev mysql.BinlogEvent) ([]*binlogdatapb.VEvent, e
tableName := tm.Name
var cols []schema.TableColumn
hasFilter := false
for _, rule := range vs.filter.Rules {
if rule.Filter != "" {
// throw error. Column name might be need in filter.
hasFilter = true
break
}
}
st := vs.se.GetTable(sqlparser.NewTableIdent(tm.Name))
vs.filter.BestEffortNameInFieldEvent = true
if st == nil {
if hasFilter || vs.filter.BestEffortNameInFieldEvent == false {
if vs.filter.BestEffortNameInFieldEvent == false {
// throw error. Column name might be need in filter.
return nil, fmt.Errorf("unknown table %v in schema", tm.Name)
}