双流 join 的场景下可以考虑关联条件引入时间属性，变成 interval join 可以实现一定的时间对齐（ https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/queries/joins/#interval-joins ） 另外如果可以使用 lookup join 单边驱动关联并且不是所有数据都需要等待的话，可以尝试 lookup join 的延迟重试 https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/queries/hints/#3-enable-delayed-retry-strategy-for-lookup
Best, Lincoln Lee casel.chen <casel_c...@126.com> 于2022年12月7日周三 11:52写道： > 有人能够解答一下吗？ > > > > > > > > > > > > > > > > > > 在 2022-11-26 11:20:34，"casel.chen" <casel_c...@126.com> 写道： > >双流关联场景下，流A数据到达后并不马上和流B进行关联，而是经过设置一段时间后再关联，这种场景下如何用flink > sql实现？如果当前不支持，需要怎样扩展flink sql呢？ >
