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

回复