flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "了不起的盖茨比" <573693...@qq.com>
Subject 回复:flink barrier对齐 理解
Date Sun, 17 May 2020 05:16:26 GMT
可以理解成,有多个subtask时候,需要等待不同subtask消费数据完毕,之后做checkpoint





------------------ 原始邮件 ------------------
发件人: Benchao Li <libenchao@gmail.com&gt;
发送时间: 2020年5月17日 11:34
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:flink barrier对齐 理解



Hi,

我对这块不是非常了解,但是我理解的barrier对齐,指的是同一个Task的多个subtask之间对齐吧。
比如你只有一个source,然后经过keyby之后做了其他的操作,那也是存在barrier对齐的。

了不起的盖茨比 <573693104@qq.com&gt; 于2020年5月17日周日 上午11:29写道:

&gt; 请教一下,如果只有一个source,就不需要对齐了吧?只有source多个数据源时候才需要对齐?



-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message