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

[往事Ψ随风]

------------------ 原始邮件 ------------------

发件人: "往事Ψ随风"<[hidden email]>;

发送时间: 2020年1月14日(星期二) 下午3:56

收件人: "user-zh-subscribe"<[hidden email]>;

主题: 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.

[Caizhi Weng]

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

往事Ψ随风 <[hidden email]> 于2020年1月14日周二 下午4:10写道：

>
>
>
> ------------------ 原始邮件 ------------------
> *发件人:* "往事Ψ随风"<[hidden email]>;
> *发送时间:* 2020年1月14日(星期二) 下午3:56
> *收件人:* "user-zh-subscribe"<[hidden email]>;
> *主题:* 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.
>
>
>
>
>
>