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 1048262223 <10...@qq.com> on 2020/06/08 10:20:21 UTC

回复： flink 任务并发顺序

Hi


Flink 是这样的，从source到sink，所以按照你的描述来说应该是完全独立的两条流，两条流之间没有关系，如下：


source(source1) -&gt; transform -&gt; sink(sink1)


source(sink1) -&gt; transform -&gt; sink(sink2)


这两条流都会独立去消费数据源，从而形成两条独立的流。


Best,
Yichao Yang




------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"小学生"<201782053@qq.com&gt;;
发送时间:&nbsp;2020年6月8日(星期一) 下午5:52
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: flink 任务并发顺序



但是，我的两个insert都是同一个job提交的，测试发现数据流入两个insert_into是随机执行的。