通过flink cdc 写入到doris中,如果表名是中文,列名是中文,数据会同步失败

Viewed 24

1.通过flink cdc 同步中文表和中文字段时,doris里面的表能创建成功,但是数据会同步失败,我通过dbever 连接doris后能添加成功数据,enable_unicode_name_support 这个参数已经设置为ture.现在的问题是通过flink cdc 同步数据的时候,如果有中文表,开启了enable_unicode_name_support 参数后创建表能成功,但是数据不能同步成功。
2.pg 数据库的ddl语句不能同步。

2 Answers

这个看样子是和label 有关系的,如果表名是中文表名的话,label中会拼接表名,这块看起来正则判断不过去。

目前是有个PR:https://github.com/apache/doris-flink-connector/pull/498/files

可以参考下着这个PR,不过这个patch后在日志里面就看不到表名了,需要评估下接受度

最新的源码里面已经没得表名验证了,我看到是调用接口的时候返回的错误。

2f2636c5ca4e5440da22ccc949ac4c9.pngeedf791fa9e8b9460edb03b3fb97a93.png