Caused by: com.starrocks.connector.flink.manager.StarRocksStreamLoadFailedException: Failed to flush data to StarRocks, Error response:

[U_1665006855435_0044]

【详述】source表里某字符串字段存在特殊字符被starrocks.connector解析的时候被转义字符代替,导致字段错位报"streamLoadErrorLog":"Error: Value count does not match column count. Expect 33, but got 20.
原始值为:0+#$151007014006
转义后为:0+\nError: Value count does not match column count. Expect 33, but got 14. Row: #$151007014006
【背景】flink1.13.2=>flink-connector-starrocks-1.2.3_flink-1.13_2.12.jar=>sr2.3.0
【StarRocks版本】例如：2.3.0
【附件】

[jingdan]

这个是行列分隔符选择有问题，建议可以配置为json写入

            .withProperty("sink.properties.format", "json")
            .withProperty("sink.properties.strip_outer_array", "true")

[jingdan]

当前sink的配置也可以发下

[U_1665006855435_0044]

我是用flink sql clinent建表,然后写sql做同步的.分隔符是建表的时候指定的:

[jingdan]

看起来是原始数据中有特殊字符，最下面那两个改成下面json导入
‘sink.properties.format’=‘json’,
sink.properties.strip_outer_array’=‘true’

[U_1665006855435_0044]

好的 谢谢 我试一试