问题一:Flink CDC中mysql cdc 报这种错误的时候异常为什么不抛出?
Flink CDC中mysql cdc 报这种错误的时候异常为什么不抛出?ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Encountered change event 'Event{header=EventHeaderV4{timestamp=1698389411000, eventType=TABLE_MAP, serverId=3436, headerLength=19, dataLength=107, nextPosition=664677625, flags=0}, data=TableMapEventData{tableId=48661632, database='autotest', table='autotest_alltype_1', columnTypes=3, 1, 2, 9, 3, 8, 4, 5, -10, 10, 19, 18, 17, 13, -2, 15, -2, 15, -4, -4, -4, -4, -4, -4, -4, -4, -2, -2, 17, 17, columnMetadata=0, 0, 0, 0, 0, 0, 4, 8, 522, 0, 0, 0, 0, 0, 65054, 150, 65034, 50, 1, 2, 3, 4, 1, 2, 3, 4, 63233, 63489, 0, 0, columnNullability={1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27}, eventMetadata=null}}' at offset {transaction_id=null, file=bin.001053, pos=664668039, gtids=7df3fe48-0640-11ed-99eb-005056b88154:1-720952314, server_id=3436, event=14} for table autotest.autotest_alltype_1 whose schema isn't known to this connector. One possible cause is an incomplete database history topic. Take a new snapshot in this case.
Use the mysqlbinlog tool to view the problematic event: mysqlbinlog --start-position=664677499 --stop-position=664677625 --verbose bin.001053
2023-10-27 14:50:11,693 ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Error during binlog processing. Last offset stored = null, binlog reader near position = bin.001053/664677499error级别,而且数据都对不上了为什么不抛出呢?debezium.inconsistent.schema.handling.mode 默认就是fail,又不是改成warn什么的
参考回答:
这个错误信息看起来是在处理MySQL的binlog时出现了问题。问题可能在于Debezium无法识别某个表的结构,可能是因为数据库历史主题不完整。
在这种情况下,Debezium建议用户使用mysqlbinlog
工具查看有问题的事件。同时,也提醒用户可能需要重新获取一个新的快照。
至于为什么没有抛出异常,可能是因为Debezium在处理这种问题时,选择了一种特殊的处理方式,即不直接抛出异常,而是记录一个错误日志,以便于开发者排查问题。这可能是因为Debezium认为这种错误并不是致命的错误,或者是为了避免频繁的异常抛出影响系统的稳定性。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566233
问题二:Flink CDC2.4.1版本 这个日志有知道是什么原因吗?
Flink CDC2.4.1版本 这个日志有知道是什么原因吗?
参考回答:
flink 现在最高是1.18版本,你指的是flink-cdc 2.4.1,日志表达的意思,看起来是你的数据和你所规定的格式不准确
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566217
问题三:Flink CDC中SQL server CDC这种报错有什么解决方式嘛?
Flink CDC中SQL server CDC这种报错有什么解决方式嘛?Caused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot.
参考回答:
这个问题很多人在 oracle cdc 遇到了,目前有 pr 在修复,sql server cdc 不清楚原因https://github.com/ververica/flink-cdc-connectors/issues/1737
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566215
问题四:Flink CDC我加上rocksdb了依赖,启动报错,还需要这个动态库什么鬼?
Flink CDC我加上rocksdb了依赖,启动报错,还需要这个动态库什么鬼?
参考回答:
抱歉给您带来了麻烦!加入 RocksDB 相关依赖之后,除了确保 RocksDB 已经安装,还要确保存储路径中的 RocksDB 动态库文件存在。如果缺失,您需要下载 RocksDB 并添加到 Flink 的 lib 路径下,确保 Flink 可以访问这些动态链接库。
在 Windows 系统上,可以在如下目录下找到 RocksDB 动态链接库:
rocksdbjni.dll librocksdbjni.dll.a librocksdbjni.dll.so
而在 Linux 系统上,需要 RocksDB 二进制包中的动态链接库文件,例如:
librocksdbjni.so libsnappy.so.1 libbz2.so.1.0 liblz4.so.1.7 libzstd.so.1.4.4 libgflags.so.2
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566209
问题五:Flink CDC中flink-sql抛了这么个错儿,有遇到吗?
Flink CDC中flink-sql抛了这么个错儿,有遇到吗?
cdc用的是2.4.1,flink是1.15
参考回答:
应该是jar包冲突了
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566203