我们是改造了kakfa-sql-connector实现的，用优先队列缓存数据 到达一定时间再发出来 datastream可以用窗口+side output来实现，但是sql没有side output实现，所以存在丢数据的情况
> 2021年6月23日 上午8:27，casel.chen <[email protected]> 写道： > > 上游有多个流需要经过flink作近实时关联，数据流有先到和后到问题，为了尽可能关联上，有什么办法可以实现延迟关联吗？每个流开个1分钟窗口再关联相同key的元素可以吗？用flink > sql如何实现？谢谢！
