Hi, Currently, Flink SQL does not support using side output for late data. For more details, you can refer to FLINK-20527[1].
One potential workaround is to use the CURRENT_WATERMARK[2] function to filter out late data in advance, and then handle it separately. [1] https://issues.apache.org/jira/browse/FLINK-20527 [2] https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/functions/systemfunctions/#temporal-functions -- Best！ Xuyang 在 2024-09-23 11:03:14，"casel.chen" <casel_c...@126.com> 写道： flink sql使用起来直接明了，但针对迟到数据默认会直接drop掉，这在某些业务场景下是不合适的，我们需要进一步分析数据延迟的原因再进行数据修复。 有没有可能通过sql hint来实现迟到数据侧输出呢？
