flink中sink出Csv格式注意

2021-04-12 15:54:53 浏览数 (1)

A1 报错

A2 原因

见官网中,需要写入元组格式

https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/datastream_api.html#data-sinks

A3 解决

csv需要以逗号作为分隔符,而tuple(元组)的toString方法正好是以逗号分割。

0 人点赞