业务场景：
Flnk消费Kafka数据后，先入Hbase，经过校验后会发送数据到Kafka另一个topic，供另一个业务线消费入库。
组件版本：
CDH：6.3.0
Flink：1.10
1. 问题描述
2. 问题定位
1、首先排查IDEA开发、编译各项编码，都是UTF-8。
2、查看服务器编码，也是UTF-8。
3、后来怀疑是hbase读写的序列化有问题，但是经测试后没有问题，直接在代码里输出中文就是乱码！
3. 解决过程
看过一些博客，是yarn的配置有问题，需要修改yarn的参数，但动作太大，没做尝试。
最简单的方式就只需在启动flink任务时加上参数就可以解决：
-yD env.java.opts="-Dfile.encoding=UTF-8 -Dsun.jnu.encoding=UTF-8"
--------------------------------END --------------------------------
希望对大家有帮助，有问题多交流
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
