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 Zhizhao Shangguan <sg...@163.com> on 2022/07/15 02:44:10 UTC

Flink SQL 能处理延时丢弃的数据吗?

Hi,ALL:

 

       咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink SQL可以实现吗? 可以话,要如何处理的?

 

Thanks♪(・ω・)ノ


Re: Re:Re: Flink SQL 能处理延时丢弃的数据吗?

Posted by Zhanghao Chen <zh...@outlook.com>.
Hi, 退订请发送任意内容至邮箱user-zh-unsubscribe@flink.apache.org

Best,
Zhanghao Chen
________________________________
From: 孙福 <su...@163.com>
Sent: Saturday, July 16, 2022 23:01
To: user-zh@flink.apache.org <us...@flink.apache.org>
Subject: Re:Re: Flink SQL 能处理延时丢弃的数据吗?

退订

















在 2022-07-15 15:06:51,"Zhizhao Shangguan" <sg...@163.com> 写道:
>  谢谢 Zhanghao。上午已经测试过了,简单功能是可以,后面会进一步验证这个试验性功能。
>
>在 2022/7/15 下午12:26,“Zhanghao Chen”<user-zh-return-15651-sgzz127=163.com@flink.apache.org 代表 zhanghao.chen@outlook.com> 写入:
>
>    你好,可以看下:https://www.mail-archive.com/issues@flink.apache.org/msg498605.html 的总结。不过这个特性还是实验性的,请谨慎使用。
>
>    Best,
>    Zhanghao Chen
>    ________________________________
>    From: Zhizhao Shangguan <sg...@163.com>
>    Sent: Friday, July 15, 2022 10:44
>    To: user-zh@flink.apache.org <us...@flink.apache.org>
>    Subject: Flink SQL 能处理延时丢弃的数据吗?
>
>    Hi,ALL:
>
>
>
>           咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink SQL可以实现吗? 可以话,要如何处理的?
>
>
>
>    Thanks♪(・ω・)ノ
>
>

Re:Re: Flink SQL 能处理延时丢弃的数据吗?

Posted by 孙福 <su...@163.com>.
退订

















在 2022-07-15 15:06:51,"Zhizhao Shangguan" <sg...@163.com> 写道:
>  谢谢 Zhanghao。上午已经测试过了,简单功能是可以,后面会进一步验证这个试验性功能。
>
>在 2022/7/15 下午12:26,“Zhanghao Chen”<user-zh-return-15651-sgzz127=163.com@flink.apache.org 代表 zhanghao.chen@outlook.com> 写入:
>
>    你好,可以看下:https://www.mail-archive.com/issues@flink.apache.org/msg498605.html 的总结。不过这个特性还是实验性的,请谨慎使用。
>
>    Best,
>    Zhanghao Chen
>    ________________________________
>    From: Zhizhao Shangguan <sg...@163.com>
>    Sent: Friday, July 15, 2022 10:44
>    To: user-zh@flink.apache.org <us...@flink.apache.org>
>    Subject: Flink SQL 能处理延时丢弃的数据吗?
>
>    Hi,ALL:
>
>
>
>           咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink SQL可以实现吗? 可以话,要如何处理的?
>
>
>
>    Thanks♪(・ω・)ノ
>
>

Re: Flink SQL 能处理延时丢弃的数据吗?

Posted by Zhizhao Shangguan <sg...@163.com>.
  谢谢 Zhanghao。上午已经测试过了,简单功能是可以,后面会进一步验证这个试验性功能。

在 2022/7/15 下午12:26,“Zhanghao Chen”<user-zh-return-15651-sgzz127=163.com@flink.apache.org 代表 zhanghao.chen@outlook.com> 写入:

    你好,可以看下:https://www.mail-archive.com/issues@flink.apache.org/msg498605.html 的总结。不过这个特性还是实验性的,请谨慎使用。

    Best,
    Zhanghao Chen
    ________________________________
    From: Zhizhao Shangguan <sg...@163.com>
    Sent: Friday, July 15, 2022 10:44
    To: user-zh@flink.apache.org <us...@flink.apache.org>
    Subject: Flink SQL 能处理延时丢弃的数据吗?

    Hi,ALL:



           咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink SQL可以实现吗? 可以话,要如何处理的?



    Thanks♪(・ω・)ノ




Re: Flink SQL 能处理延时丢弃的数据吗?

Posted by Zhanghao Chen <zh...@outlook.com>.
你好,可以看下:https://www.mail-archive.com/issues@flink.apache.org/msg498605.html 的总结。不过这个特性还是实验性的,请谨慎使用。

Best,
Zhanghao Chen
________________________________
From: Zhizhao Shangguan <sg...@163.com>
Sent: Friday, July 15, 2022 10:44
To: user-zh@flink.apache.org <us...@flink.apache.org>
Subject: Flink SQL 能处理延时丢弃的数据吗?

Hi,ALL:



       咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink SQL可以实现吗? 可以话,要如何处理的?



Thanks♪(・ω・)ノ