转发：1.90版本的Flinksql相关使用问题

[往事Ψ随风 <13...@qq.com>]

------------------ 原始邮件 ------------------
发件人:&nbsp;"往事Ψ随风"<1322015085@qq.com&gt;;
发送时间:&nbsp;2020年1月14日(星期二) 下午3:56
收件人:&nbsp;"user-zh-subscribe"<user-zh-subscribe@flink.apache.org&gt;;

主题:&nbsp;1.90版本的Flinksql相关使用问题



关于FlinkSQL的相关问题：1、请问使用Flink1.90版本的sql实现从Kafka读取数据，统计，输出数据到Kafka，数据格式是以csv形式的，kafka的format那块请问怎么写?
报错如下：




Caused by: org.apache.flink.table.api.ValidationException: Could not map the schema field 'fruit' to a field from source. Please specify the source field from which it can be derived.

Re: 1.90版本的Flinksql相关使用问题

[Caizhi Weng <ts...@gmail.com>]

Hi,
邮件里的图片挂了，请上传到外部图库并把链接贴在邮件里。
format 等的填写可以参考：
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connect.html

往事Ψ随风 <13...@qq.com> 于2020年1月14日周二 下午4:10写道：

>
>
>
> ------------------ 原始邮件 ------------------
> *发件人:* "往事Ψ随风"<13...@qq.com>;
> *发送时间:* 2020年1月14日(星期二) 下午3:56
> *收件人:* "user-zh-subscribe"<us...@flink.apache.org>;
> *主题:* 1.90版本的Flinksql相关使用问题
>
> 关于FlinkSQL的相关问题：
>
> 1、请问使用Flink1.90版本的sql实现从Kafka读取数据，统计，输出数据到Kafka，数据格式是以csv形式的，kafka的format那块请问怎么写?
> 报错如下：
>
> Caused by: org.apache.flink.table.api.ValidationException: Could not map
> the schema field 'fruit' to a field from source. Please specify the source
> field from which it can be derived.
>
>
>
>
>
>