大部分情况下,可以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/
