使用flink sql join临时表，出现异常（Flink-1.10.0）

[amenhub <am...@163.com>]

各位好：


  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

Re: Re: 使用flink sql join临时表，出现异常（Flink-1.10.0）

["amenhub@163.com" <am...@163.com>]

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 <am...@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
>
>
>
>

Re: 使用flink sql join临时表，出现异常（Flink-1.10.0）

[Jark Wu <im...@gmail.com>]

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 <am...@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
>
>
>
>