You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2023/06/28 00:35:19 UTC

Flink CDC消费MySQL Binlog出现中文乱码问题

mysql库中设置的是utf8mb4编码,单独sql查询mysql表没有出现中文乱码
使用flink datastream作业通过cdc消费mysql binlog并写到下游doris表时遇到字符串长度超长问题,我们是按mysql表schema创建的doris schema,就很奇怪为什么总是报字符串超长错误。于是将异常时的原始数据打印出来,才发现数据中只要包含了中文字符都会显示成乱码,要么都是???,要么都是其他莫名字符。
我按照网上搜索解答在flink-conf.yaml中添加了env.java.options=UTF-8,结果测下来还是会报同样的异常。请问这个问题要怎么彻底解决?谢谢!