Flink CDC中flinksql window 不支持设置allowedLateness？

在当前的Flink CDC版本中，基于窗口表函数的聚合操作不支持直接设置allowedLateness（允许延迟数据）参数。allowedLateness参数通常用于定义窗口聚合操作的最大允许延迟时间，允许后续到达的事件数据仍然被视为属于该窗口。

然而，您仍然可以通过其他方式来处理延迟数据并进行窗口聚合操作。以下是一种可能的解决方案：

使用Flink的EventTime语义：确保您的数据流中包含事件时间（Event Time）字段，并通过调用assignTimestampsAndWatermarks方法为数据流分配事件时间戳和水印。

使用窗口函数和迟到数据处理：使用Flink的窗口函数（Window Function）和迟到数据处理功能来处理延迟数据。

定义窗口：在SQL语句中，使用TUMBLE、HOP或SESSION等窗口函数定义您所需的窗口类型和窗口大小。

注册迟到数据处理函数：在Flink的TableEnvironment中，使用registerFunction方法注册一个自定义的迟到数据处理函数（Late Data Processing Function）。

应用迟到数据处理：在窗口函数中，使用自定义的迟到数据处理函数来处理迟到的数据。根据具体需求，您可以选择将迟到数据丢弃、发送到侧输出流（Side Output）或延迟触发窗口计算。