flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

schema isn't known to connector

Open z070204z opened this issue 3 years ago • 2 comments

when scan newly added tables if i set startupOptions=StartupOptions.latest() throw Error

ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Encountered change event 'Event{header=EventHeaderV4{timestamp=1653474984000, eventType=TABLE_MAP, serverId=1, headerLength=19, dataLength=33, nextPosition=999048757, flags=0}, data=TableMapEventData{tableId=302, database='test', table='src', columnTypes=15, 15, 3, columnMetadata=765, 765, 0, columnNullability={0, 1}, eventMetadata=null}}' at offset {transaction_id=null, ts_sec=1653474975, file=mysql-bin.000021, pos=999048633, server_id=1, event=1} for table test.src whose schema isn't known to this connector. One possible cause is an incomplete database history topic. Take a new snapshot in this case.

z070204z avatar May 26 '22 01:05 z070204z

我也遇到了 ++1

ysyl23588 avatar May 26 '22 14:05 ysyl23588

the table not in savepoint state

Peng-89 avatar Sep 17 '22 04:09 Peng-89

I set startupOptions=StartupOptions.inital() , still encounter this problem,So, besides not starting from the state, is there a better way?

OrangeLinforCode avatar Jul 05 '23 09:07 OrangeLinforCode

I set startupOptions=StartupOptions.inital() , still encounter this problem,So, besides not starting from the state, is there a better way?

I tested the latest version 2.4.0, everything is working fine.

z070204z avatar Aug 02 '23 07:08 z070204z