大部分情况下,可以work,但是有一些边界的情况,可能会有问题。比如第一个sink的作业,由于某种原因,处理得比较慢,延迟比较大?

也就是说,通常情况下可能没有问题,但是由于这2个作业之间没有任何依赖关系,这个先后顺序是得不到保证的。

我觉得你可以测一下,如果能接受那些极端情况,就可以。

> 在 2020年7月10日,下午5:08,lgs <[email protected]> 写道:
> 
> 代码顺序是指我先写第一个sink的代码,再写第二个sink的代码。
> 
> 我设置了'connector.write.flush.max-rows' = '1'
> 第一个sink没有窗口,所以直接写了
> 
> 第二个sink有窗口,所以是会在一个小时的最后触发。
> 
> 可能这样就能保证第二个sink能够读到最新的数据。
> 
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复