FOR SYSTEM_TIME AS OF 维表关联 报错

[阿华田]

各位大佬 在flink sql客户端执行维度关联报错
sql语句：insert into  sink_a select a.user_id, b.user_name  from source_a as a left join source_b  FOR SYSTEM_TIME AS OF a.proc_time  b on a.user_id = b.user_id;
报错信息
[ERROR] Could not execute SQL statement. Reason:
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, ModifyKindSetTraitDef=[NONE], UpdateKindTraitDef=[NONE].
Missing conversion is FlinkLogicalJoin[convention: LOGICAL -> STREAM_PHYSICAL]
There is 1 empty subset: rel#280:Subset#14.STREAM_PHYSICAL.any.None: 0.[NONE].[NONE], the relevant part of the original plan is as follows
| |
阿华田
|
|
[hidden email]
|
签名由网易邮箱大师定制