Flink CDC里mysql->doris,报错 ，这个什么原因？
Flink CDC里mysql->doris,报错 ，这个什么原因？数据列数太多，还是说数据里面有特殊字符？还是其他原因？
我用Doris官方推荐的整库同步可以成功同步，flinkcdc的pipeline整库同步就是上面的报错。我想的是这个表列数过多，或者字段内容中有特殊字符导致的。主要是不知道怎么解决？实际导入字段长度过长，比建表字段长。但它给的错误值我去mysql源表中去查，根本找不到。我自己手动按mysql的字符串长度去手动建了个做测试。可能是这个。自动建表varchar 类型，doris那边会加倍数可能用的字符集不一样。异常三倍。
写回答
-
太多被过滤的列，应该是某些原因导致数据无法插入doris。看一下这个地址里的内容
doris、starocks的字符串的长度和mysql的不一样，一般是doris、starocks最好按照mysql字段的3倍长度来建表。doris/starrocks. VARCHAR(n)a. 变长字符串，长度范围为：1-65533 字节长度，以 UTF-8 编码存储的，因此通常英文字符占 1 个字节，中文字符占 3 个字节。这里的n指的是字节数
MySQL中varchar(n)表示n个字符，无论汉字和英文。此回答来自钉群Flink CDC 社区 。
2024-04-03 11:55:35赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关课程
更多
相关文章
相关电子书
更多
