各位好:

  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



回复