是 MySQL_tableB 所在的 server 端字符设置有问题。
配置中加上下面的配置就好了。
[mysqld] character-set-server=utf8 [client] default-character-set=utf8 [mysql] default-character-set=utf8
[hidden email]
发件人:
[hidden email]
发送时间: 2020-07-15 16:34
收件人: user-zh
主题: FlinkSQL 入到 MySQL后汉字乱码
KafkaTable: kafka 消息
MySQL_tableA: 维表,维表里 value 是汉字
MySQL_tableB: join后的结果表。和 MySQL_tableA 不在同一台服务器上。
我直接在 flink sql client SELECT 是可以正常显示, 但 INSERT INTO MySQL_tableB SELECT 后到 MySQL_tableB 里去查看,汉字就乱码了。
大家有什么建议吗?
谢谢,
王磊
[hidden email]