中文字段从MySQL同步到starrocks中,字段内容全部为null

【详述】
mysql 版本 5.7
flink 版本 1.13.6
starrocks版本3.0.0
flink-connector-starrocks 版本 1.2.6
我碰到个问题,MySQL通过flink同步到starrocks,中文字段全部为null,英文字段是正常的,大家有碰到过吗?MySQL建表和插入语句:
create table cn_field(f1 int primary key,中文 varchar(20));
insert into cn_field values (1,‘a1’),(2,‘b2’),(3,‘c3’);
starrocks里面的表是
CREATE TABLE cn_field ( f1 int(11) NOT NULL COMMENT “”, 中文 varchar(65533) NULL COMMENT “”) ENGINE=OLAP PRIMARY KEY(f1)COMMENT "OLAP"DISTRIBUTED BY HASH(f1) BUCKETS 2 PROPERTIES (“replication_num” = “1”,“in_memory” = “false”,“storage_format” = “DEFAULT”,“enable_persistent_index” = “false”,“replicated_storage” = “true”,“compression” = “LZ4”);
【背景】flink中通过sql接口建MySQL和starrocks对应的表,然后insert into starrocks_table select * from mysql_table
【业务影响】
【StarRocks版本】例如:3.0.0
【集群规模】例如:1fe+1be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:16C/16G/千兆
【表模型】例如:主键模型
【导入或者导出方式】例如:Flink
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息,请补充下您的联系方式,例如:weishishuo329@qq.com,谢谢
【附件】

  • fe.log/be.INFO/相应截图

中文字段是utf8编码格式么,另外有在flink中做什么处理么,没有的话可以试试 创建mysql外表mysql_external_tbl,然后insert into starrocks_table select * from mysql_external_tbl,看一下直接从mysql外表同步数据,中文字段显示是否正常 https://docs.starrocks.io/zh-cn/latest/data_source/External_table#mysql-外部表

创建外表并插入starrocks表是正常的。 flink里面没有做处理,也是直接用sql接口insert的。中文字段是utf8编码的

按照提供的建表语句,也就是说mysql中的数据中文长度在varchar(20)以内,检查下 flink中table api建表字段长度设置的多长,长度是够的么