flink sql cdc现在支持interval join嘛？

Flink SQL CDC 目前 不支持 Interval Join 操作。以下是详细说明：

1. Interval Join 的限制

根据知识库中的描述，Interval Join 在 Flink SQL 中的实现存在以下限制： - Interval Join 不支持更新流作为输入。 - 更新流是指包含 UPDATE 或 DELETE 类型事件的 Changelog 数据流，而 CDC 数据源通常会生成更新流（例如，通过 Debezium 或 Maxwell 捕获的 MySQL binlog 数据）。

2. CDC 数据流的特点

CDC 数据流通常包含以下事件类型： - INSERT - UPDATE_BEFORE 和 UPDATE_AFTER - DELETE

这些事件类型构成了更新流，而 Interval Join 的运行时算子（IntervalJoin）明确标注为 不支持处理更新流。因此，当使用 CDC 数据源时，Interval Join 无法正确处理包含更新或删除操作的数据流。

3. 状态迁移与兼容性问题

此外，Interval Join 相关算子的状态迁移目前也不被支持。这意味着即使尝试对 Interval Join 进行某些变更（如调整时间范围或条件），也可能导致状态不兼容的问题，进一步限制了其在 CDC 场景中的应用。

4. 替代方案

如果需要在 CDC 数据流中实现类似 Interval Join 的功能，可以考虑以下替代方案： - Temporal Join：Temporal Join 支持处理更新流，并且可以基于时间版本化的表进行关联操作。 - 窗口聚合（Window Aggregation）：通过定义时间窗口，可以在窗口范围内对数据进行聚合或关联操作。

总结

综上所述，Flink SQL CDC 当前 不支持 Interval Join，因为 Interval Join 无法处理 CDC 数据流中的更新事件。如果需要处理 CDC 数据流，建议使用 Temporal Join 或窗口聚合等替代方案。