重启canal后某些情况下parseEvent失败无法继续

异常如下：

2014-09-23 12:49:09.635 [destination = db2 , address = /10.15.2.116:3306 , EventParser] ERROR com.alibaba.otter.canal.common.alarm.LogAlarmHandler - destination:db2[com.alibaba.otter.canal.parse.exception.CanalParseException: com.alibaba.otter.canal.parse.exception.CanalParseException: parse row data failed. Caused by: com.alibaba.otter.canal.parse.exception.CanalParseException: parse row data failed. Caused by: com.alibaba.otter.canal.parse.exception.TableIdNotFoundException: not found tableId:71

此异常会一直不断重复，导致binlog的消费停留在此LogPosition不往下继续。

触发场景： 停掉canal后启动.

异常情况原因推断是因为重启后遇到的binlog event没有TABLE_MAP_EVENT开头，而恰好直接出现后续的event，导致logContext的table字段未设置

通过查询异常的出现点在：

com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert private Entry parseRowsEvent(RowsLogEvent event) { try { TableMapLogEvent table = event.getTable(); if (table == null) { // tableId对应的记录不存在 throw new TableIdNotFoundException("not found tableId:" + event.getTableId()); } ...

event的table字段设置：

com.taobao.tddl.dbsync.binlog.event.RowsLogEvent public final void fillTable(LogContext context) { table = context.getTable(tableId);

    // end of statement check:
    if ((flags & RowsLogEvent.STMT_END_F) != 0)
    {
        // Now is safe to clear ignored map (clear_tables will also
        // delete original table map events stored in the map).
        context.clearAllTables();
    }
}

com.taobao.tddl.dbsync.binlog.LogContext public final void putTable(TableMapLogEvent mapEvent) { mapOfTable.put(Long.valueOf(mapEvent.getTableId()), mapEvent); }

com.taobao.tddl.dbsync.binlog.LogDecoder.decode 方法 case LogEvent.TABLE_MAP_EVENT: { TableMapLogEvent mapEvent = new TableMapLogEvent(header, buffer, descriptionEvent); /* updating position in context */ logPosition.position = header.getLogPos(); context.putTable(mapEvent); return mapEvent; }

原提问者GitHub用户ChinaXing