You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 吴先生 <15...@163.com> on 2023/03/13 10:29:34 UTC

Flink-Sql Watermarkers问题

hi，
我在使用Flink-Sql 1.14版本时能否不在create table处指定watermarkers，因为源数据需要做一些清洗之后再指定水位线


| |
吴先生
|
|
15951914547@163.com
|

Re: Flink-Sql Watermarkers问题

Posted by ying lin <br...@gmail.com>.
Flink SQL 现在只能在create table 语句中指定watermark，另外一种迂回的做法，就是参考一下Flink SQL
把Tabe转成流，然后在流上做清洗后再指定watermark

回复： Flink-Sql Watermarkers问题

Posted by 吴先生 <15...@163.com>.
好的感谢，我关注下


| |
吴先生
|
|
15951914547@163.com
|
---- 回复的原邮件 ----
| 发件人 | Shammon FY<zj...@gmail.com> |
| 发送日期 | 2023年3月13日 18:49 |
| 收件人 | <us...@flink.apache.org> |
| 主题 | Re: Flink-Sql Watermarkers问题 |
Hi

目前sql只能在create table时指定，不过有新的扩展功能，相关FLIP正在讨论中，你可以关注一下
https://cwiki.apache.org/confluence/display/FLINK/FLIP-296%3A+Extend+watermark-related+features+for+SQL

Best,
Shammon.FY

On Mon, Mar 13, 2023 at 6:29 PM 吴先生 <15...@163.com> wrote:

hi，
我在使用Flink-Sql 1.14版本时能否不在create table处指定watermarkers，因为源数据需要做一些清洗之后再指定水位线


| |
吴先生
|
|
15951914547@163.com
|

Re: Flink-Sql Watermarkers问题

Posted by Shammon FY <zj...@gmail.com>.
Hi

目前sql只能在create table时指定，不过有新的扩展功能，相关FLIP正在讨论中，你可以关注一下
https://cwiki.apache.org/confluence/display/FLINK/FLIP-296%3A+Extend+watermark-related+features+for+SQL

Best,
Shammon.FY

On Mon, Mar 13, 2023 at 6:29 PM 吴先生 <15...@163.com> wrote:

> hi，
> 我在使用Flink-Sql 1.14版本时能否不在create table处指定watermarkers，因为源数据需要做一些清洗之后再指定水位线
>
>
> | |
> 吴先生
> |
> |
> 15951914547@163.com
> |