我不太明白你说的“代码顺序”指的什么？ 据我所知，应该没有什么太好的办法。从执行图上来看，这2个之间没有依赖关系，所以也就无法保证先后顺序。
如果必须这样干的话，你得从业务的角度想一下，改造一下业务逻辑。 > 在 2020年7月10日，下午4:10，lgs <[email protected]> 写道： > > 这次可以了。谢谢 > > 另外还有一个问题请教一下： > 我实际上是有另一个sink，source是同一个。 > 第一个sink是直接保存kafka数据到DB。 > 第二个sink是读取kafka，tumble window，然后在udf里面去读取DB。 > > 要怎么样保证第一个sink写完了DB，然后第二个sink的udf能读取到最新的数据？ > > 代码的顺序就能保证吗？ > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
