Flink CDC中这个报错如何解决？cdc2.4，flink1.6，mysql8

Flink CDC中这个报错如何解决，cdc2.4，flink1.6，mysql8；
Flink SQL> select * from mysql_binlog;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassCastException: cannot assign instance of com.ververica.cdc.connectors.shaded.com.fasterxml.jackson.databind.ObjectMapper to field com.ververica.cdc.connectors.mysql.table.MySqlDeserializationConverterFactory$2.val$objectMapper of type com.fasterxml.jackson.databind.ObjectMapper in instance of ...

展开

收起

小易01 2023-07-24 21:42:24 145 0

3 条回答

写回答

取消提交回答

算精通

北京阿里云ACE会长

以下是一些可能与 Flink CDC、Flink 和 MySQL 版本不兼容相关的问题以及相应的解决方案：
报错信息：com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Unknown system variable 'tx_isolation'
解决方案：这种错误可能是由于 MySQL 8 不再支持 tx_isolation 系统变量引起的。建议将 Flink CDC 的 MySQL 连接 URL 中的 tx_isolation 配置设置为 SERIALIZABLE 或删除该配置。
报错信息：java.lang.UnsupportedOperationException: Cannot create a TypeInformation for a class that is not a POJO: class org.apache.flink.types.Row
解决方案：这种错误可能是由于 Flink CDC 2.4 和 Flink 1.6 不支持使用 Row 类型作为返回类型引起的。建议将返回类型更改为 POJO 类型，或者将 Flink 升级到支持 Row 类型的版本。

2023-07-29 18:44:38

赞同展开评论打赏
意中人jswy

意中人就是我呀！

疑似flink sql mysql connector 和 flink mysql connector冲突了，一般统一用flink sql connector。可能是打包JAR时，把依赖打进去了。要么就是打包时不要打Connector的依赖，要么就是lib里不要留Connector的依赖，二选一。此回答整理至钉群“Flink CDC 社区”

2023-07-26 12:01:19

赞同展开评论打赏
武当张三丰丶

存在即是合理

应该是在执行 SQL 语句时出现了类型转换异常。具体来说，它指出无法将 com.ververica.cdc.connectors.shaded.com.fasterxml.jackson.databind.ObjectMapper 类型的实例分配给 com.ververica.cdc.connectors.mysql.table.MySqlDeserializationConverterFactory$2.val$objectMapper 类型的字段。

可能是由于Flink CDC版本与 MySQL 版本不兼容导致的。可以尝试升级或降级 Flink CDC 版本，或者升级 MySQL 版本来解决这个问题。也要可以检查 Flink SQL 中是否正确配置了 MySQL 连接器参数，例如用户名、密码、主机名等。

2023-07-25 16:40:01

赞同展开评论打赏