flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jimmy Wong" <wangzmk...@163.com>
Subject 回复:keyby的乱序处理
Date Mon, 30 Mar 2020 13:13:27 GMT
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化的乱序处理能支持吗
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message