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

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

转发: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.





Reply | Threaded
Open this post in threaded view
|

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

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.
>
>
>
>
>
>