问题一:Flink CDC知道这个报错是啥意思?
Flink CDC知道这个报错是啥意思?
参考回答:
这个报错信息表示在Flink CDC中,程序试图加载一个名为"ENABLE_STATE这个报错信息表示在Flink CDC中,程序试图加载一个名为"ENABLE_STATE_CHANGE_LOG"的断点,但是找不到这个文件。这可能是因为配置文件中缺少了这个断点的设置,或者该断点的名称拼写错误。请检查配置文件并确保断点名称正确。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/570695
问题二:flinkcdc直接连mysql的,mysql库的用户我赋权了,但是还报错这个,大家有遇到过么?
flinkcdc直接连mysql的,mysql库的用户我赋权了,但是还报错这个,大家有遇到过么。
Caused by: java.lang.IllegalArgumentException: Can't find any matched tables, please check your configured database-name: [energo_saas_2.0_config
] and table-name: [`energo_saas_2.0_config.table_process]
at com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils.discoverCapturedTables(DebeziumUtils.java:175)
at com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner.discoveryCaptureTables(MySqlSnapshotSplitAssigner.java:172)
... 13 more?
参考回答:
表名或数据库名不对吧
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/570690
问题三:flink cdc 任务启动后加表读binlog报错有人碰到没?
flink cdc 任务启动后加表读binlog报错有人碰到没?2023-11-09 19:30:05,620 ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Error during binlog processing. Last offset stored = {transaction_id=null, ts_sec=1699529405, file=mysql-bin.017726, pos=137351975, gtids=c90e9a14-a29d-11eb-8263-fa163e4737cc:1-118537222,cce375bc-a29d-11eb-bfaa-fa163e1154f1:1-2742775008, server_id=676171852, event=5}, binlog reader near position = mysql-bin.017726/137354061
2023-11-09 19:30:05,633 ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Encountered change event 'Event{header=EventHeaderV4{timestamp=1699529405000, eventType=TABLE_MAP, serverId=676171852, headerLength=19, dataLength=82, nextPosition=137364414, flags=0}, data=TableMapEventData{tableId=642, database='flp', table='fx_access_info', columnTypes=8, 8, 8, 15, 15, 15, 3, 15, 15, 15, 1, 15, 15, 15, 15, 15, 1, 18, 18, 3, columnMetadata=0, 0, 0, 192, 96, 765, 0, 765, 765, 765, 0, 384, 765, 300, 48, 48, 0, 3, 3, 0, columnNullability={13, 14, 15}, eventMetadata=null}}' at offset {transaction_id=null, ts_sec=1699529405, file=mysql-bin.017726, pos=137361711, gtids=c90e9a14-a29d-11eb-8263-fa163e4737cc:1-118537226,cce375bc-a29d-11eb-bfaa-fa163e1154f1:1-2742775008, server_id=676171852, event=14} for table flp.fx_access_info whose schema isn't known to this connector. One possible cause is an incomplete database history topic. Take a new snapshot in this case. flink doris connector 启动的,动态加表
参考回答:
加表是动态加表吧,mysql的,我指的是cdc的启动方式,init 默认全量启动还是时间戳启动,点位启动
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/570684
问题四:Flink CDC这个啥问题?
Flink CDC这个啥问题?这个主节点sync_log是1来着,然后报错总是找不到对应的binlog,这是最新版本的cdc
参考回答:
这个问题可能是由于Flink CDC在获取MySQL的binlog时出现了问题。Flink CDC是通过读取MySQL的binlog来获取数据的,如果它无法找到对应的binlog,那么就无法获取到数据。
这个问题可能与MySQL的配置、Flink CDC的配置或者网络环境有关。以下是一些可能的解决方案:
- 检查MySQL的配置,确保binlog是开启的,并且Flink CDC有权限访问binlog。
- 检查Flink CDC的配置,确保它正确地配置了MySQL的地址和端口,以及binlog的位置。
- 检查网络环境,确保Flink CDC能够正常地访问MySQL的binlog。
- 如果可能,可以尝试重启MySQL服务器,或者重新部署Flink CDC任务,看看是否能够解决问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/570683
问题五:flinkcdc同步4张现在都还在卡住?
flinkcdc同步4张现在都还在卡住?Caused by: io.debezium.DebeziumException: java.lang.NullPointerException
at com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.execute(MySqlSnapshotSplitReadTask.java:120)
at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.lambda$submitSplit$0(SnapshotSplitReader.java:130)
... 5 more
Caused by: java.lang.NullPointerException
at com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.createDataEventsForTable(MySqlSnapshotSplitReadTask.java:206)
at com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.createDataEvents(MySqlSnapshotSplitReadTask.java:193)
at com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.doExecute(MySqlSnapshotSplitReadTask.java:154)
at com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.execute(MySqlSnapshotSplitReadTask.java:115)
... 6 more
参考回答:
库名表名加上 `` 反引号试试看
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/570677