【详述】
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/相应截图