Hi amenhub, 目前还不支持 event time 的 temporal table join。
你可以试试是否可以用 temporal table function join [1], 这个是支持 event time join 的。 Best, Jark [1]: https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/joins.html#join-with-a-temporal-table-function On Thu, 20 Feb 2020 at 16:57, amenhub <[email protected]> wrote: > 各位好： > > > 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 > > > >
