flink两个流join的时候怎么解决数据延迟问题

现在做的数仓，想转实时这一块儿，正在学习，生产中两个流join时，怎么解决数据延迟呢，如果数据超出水位线怎么办。

OutputTag获取迟到数据，二次消费