flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "amenhub@163.com" <amen...@163.com>
Subject Re: Re: 使用flink sql join临时表,出现异常(Flink-1.10.0)
Date Fri, 21 Feb 2020 09:45:45 GMT
hi Jark,

非常感谢您的回复,建议是有效的,谢谢!

Best, 
amenhub



amenhub@163.com
 
发件人: Jark Wu
发送时间: 2020-02-21 16:12
收件人: user-zh
主题: Re: 使用flink sql join临时表,出现异常(Flink-1.10.0)
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 <amenhub@163.com> 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
>
>
>
>
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message