flink1.13.6 版本 使用flink sql interval left join 不生效

问题描述： 您在使用Flink的Interval Join执行Left Join操作时，遇到输出结果中包含撤回流（-U消息），且左表数据即使未与右表匹配，也持续输出到Kafka。您怀疑这可能是由于使用的Flink版本较低，不支持Interval Left Join。

背景信息：

• Interval Join允许两个流根据时间区间进行关联，确保左流中的每条记录只与右流中满足特定时间范围内的数据相连接。
• Left Join默认保留左表的所有记录，即使没有匹配项。
• Flink SQL的Join操作在某些情况下会生成状态（State）以处理更新流，而Interval Join算子通常不支持状态迁移，但特定条件下变更可视为兼容。

解决方案：

• 首先，确认您的Flink版本是否确实支持Interval Join以及其在不同Join类型下的行为。虽然文档未直接指出版本对Interval Left Join的支持限制，但了解具体版本特性是关键。
• 确保您的TIMEBOUND_EXPRESSION设置正确，避免了无匹配情况下的错误输出。例如，应确保时间条件表达式如ltime BETWEEN rtime - INTERVAL 'x' AND rtime + INTERVAL 'y'准确反映了预期的匹配规则。
• 检查您的作业配置，特别是与状态兼容性相关的参数，比如table.optimizer.state-compatibility.ignore-filter，看是否因配置不当导致了意外的撤回流输出。
• 考虑到左表数据即便无匹配也持续输出，检查是否因为左表数据的事件时间或水印处理有误，导致系统无法正确识别匹配窗口的结束。

注意事项：

• 版本兼容性：查阅官方文档或社区讨论，确认您的Flink版本对Interval Join及特定Join类型的完整支持情况。
• 时间边界：精确设置时间边界条件，确保仅在有效时间范围内寻找匹配。
• 状态管理：正确配置作业参数，避免因状态管理不当引发的数据不一致。

总结： 问题可能并非直接由版本过低造成，而是与时间边界设定、状态管理配置或数据流的时间特性相关。建议从这些方面入手排查，并参考Flink官方文档和社区资源来确定具体原因和解决方案。