flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amenhub <amen...@163.com>
Subject 使用flink sql join临时表,出现异常(Flink-1.10.0)
Date Thu, 20 Feb 2020 08:57:05 GMT
各位好:


  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



Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message