flink_doris_connector处理带有回车符的字段数据

[Xie Josh]

Mysql中有字段值带有\n的回车符('直臂\n焊接'),

在flinksql中用replace(str,'\n','')方式处理,

结果还是被doris截断成两条数据, 导致原本一条数据被\n 截断成两条 造成导入列和目标列数量不匹配的问题

有什么办法处理嘛?

[cid:image001.png@01D803CA.1B4AE580]