Flink SQL 自身机制无法保证同一个作业多个 sink 的写入次序。 是否可以考虑从业务逻辑上动手脚，比如写入消息队列 sink 前加个 udf filter, udf 查询 database，满足条件才写入消息队列，当然这种方式对性能可能有影响。
On Wed, Oct 12, 2022 at 2:41 PM Zhiwen Sun <pens...@gmail.com> wrote: > hi all： > > 我们有个场景，需要 Flink SQL 同时写入消息和 database， 后续实时任务消费消息，再次读取 database， 如果消息先于 > database 写入，这就可能导致读取的数据不正确。 > > 是否有办法保证 database 写入后，再发送消息？ > > Zhiwen Sun >
