flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "蒋佳成(Jiacheng Jiang)" <920334...@qq.com>
Subject 回复: keyby的乱序处理
Date Tue, 31 Mar 2020 01:51:12 GMT
keyby后加watermark后面只能是windowAll,难道还要keyby一下?




------------------&nbsp;原始邮件&nbsp;------------------
发件人: "tingli ke"<ketingli92@gmail.com&gt;; 
发送时间: 2020年3月31日(星期二) 上午9:48
收件人: "user-zh"<user-zh@flink.apache.org&gt;; 
主题: Re: keyby的乱序处理



您好,
非常感谢您的回复!
key化就是keyby之后的,个人理解为keyed(key&nbsp;化),和您回答的“watermark&nbsp;可以在&nbsp;keyBy&nbsp;后分配”是同一个话题。

Jimmy&nbsp;Wong&nbsp;<wangzmking@163.com&gt;&nbsp;于2020年3月30日周一&nbsp;下午9:13写道:

&gt;&nbsp;Hi,
&gt;&nbsp;watermark&nbsp;可以在&nbsp;keyBy&nbsp;后分配,但是最好紧跟&nbsp;SourceFunction。经过&nbsp;KeyBy
&gt;&nbsp;或其他分配策略,可能导致数据更大的延迟(EventTime)。
&gt;
&gt;
&gt;&nbsp;“想做key化的乱序处理”&nbsp;这句没太理解,麻烦解释下。
&gt;
&gt;
&gt;&nbsp;|&nbsp;|
&gt;&nbsp;Jimmy&nbsp;Wong
&gt;&nbsp;|
&gt;&nbsp;|
&gt;&nbsp;wangzmking@163.com
&gt;&nbsp;|
&gt;&nbsp;签名由网易邮箱大师定制
&gt;
&gt;
&gt;&nbsp;在2020年03月30日&nbsp;20:58,tingli&nbsp;ke<ketingli92@gmail.com&gt;&nbsp;写道:
&gt;&nbsp;请教一个问题:kafka-per-partition&nbsp;的watermark的分配,可以在keyby之后分配吗,想做key化的乱序处理能支持吗
&gt;
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message