StarRocksSink怎么插入特殊字符

采用flink读取json写入StarRocksSink.sink时,json中有特殊字符,一直报string转成json,里面有特殊字符。 像这种情况该如何导入数据

具体错误信息是?可以上传下connector配置和日志文件。

业务人员给的建议是库表里面有特殊符号 例如\t 表情之类的。MySQL是用utf8mb4字符集存放的,所以咱们这个starrocks有什么办法可以存嘛

connector配置发下

大佬 有什么好的方案没

source的json怎么构建的?

读取mysql的
里面有一些null值的数据 也有一些特殊符号的数据

mysql为什么不直接用flink-cdc呢?

有其他的操作
用不了呀

json的value要是很多null值会有这个问题嘛?

要看下您那边source怎么构建的json,建议还是用现有的source connector来操作,具体是什么原因用不了cdc方便说下么?