问题

如果需要cdc的mysql表中包含“特殊的字段”比如 name count 。这种是不是就不能同步了，flink的 sql.parser 解析这样的字段会抛出异常.

解决方法

flinksql和hivesql一样,都是使用反引号作为特殊字符的标记.

eg:

select `name` from table1;

如果觉得《flinksql处理特殊字符》对你有帮助，请点赞、收藏，并留下你的观点哦！