各位好:
Flink-1.10.0 可以使用处理时间属性进行 temporal join,当我尝试以下面的 sql 提交 flink 任务时, 【 SELECT m.name, m.age, m.score FROM mysql_out AS m JOIN kafka_out FOR SYSTEM_TIME AS OF m.update_time AS k ON m.name = k.name 】 出现了如下异常: 【 Caused by: org.apache.calcite.plan.RelOptPlanner$CannotPlanException: There are not enough rules to produce a node with desired properties: convention=STREAM_PHYSICAL, FlinkRelDistributionTraitDef=any, MiniBatchIntervalTraitDef=None: 0, UpdateAsRetractionTraitDef=false, AccModeTraitDef=UNKNOWN.Missing conversion is FlinkLogicalJoin[convention: LOGICAL -> STREAM_PHYSICAL] 】 请大佬答疑解惑,感谢 祝好,amenhub