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 "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/03/31 01:51:12 UTC
回复: keyby的乱序处理
keyby后加watermark后面只能是windowAll,难道还要keyby一下?
------------------ 原始邮件 ------------------
发件人: "tingli ke"<ketingli92@gmail.com>;
发送时间: 2020年3月31日(星期二) 上午9:48
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: keyby的乱序处理
您好,
非常感谢您的回复!
key化就是keyby之后的,个人理解为keyed(key 化),和您回答的“watermark 可以在 keyBy 后分配”是同一个话题。
Jimmy Wong <wangzmking@163.com> 于2020年3月30日周一 下午9:13写道:
> Hi,
> watermark 可以在 keyBy 后分配,但是最好紧跟 SourceFunction。经过 KeyBy
> 或其他分配策略,可能导致数据更大的延迟(EventTime)。
>
>
> “想做key化的乱序处理” 这句没太理解,麻烦解释下。
>
>
> | |
> Jimmy Wong
> |
> |
> wangzmking@163.com
> |
> 签名由网易邮箱大师定制
>
>
> 在2020年03月30日 20:58,tingli ke<ketingli92@gmail.com> 写道:
> 请教一个问题:kafka-per-partition 的watermark的分配,可以在keyby之后分配吗,想做key化的乱序处理能支持吗
>