???????????????????????????? Join ???? ?????????????????????????????????????????????????????????????????? Join ?? ?????? Join ?????????????????????????? Join ???????????????????????? Join ?????????????? ???????????????? join ??????????????????????????????????????????????????????????????????????????????????????????????????????, ??????????????????????????
????????????????????????????????????????????????????watermark???????????????????????? [email protected] ???????? op ?????????? 2021-06-23 17:03 ???????? user-zh ?????? Processing-time temporal join is not supported yet hi??????????kaka????temporal join?????????????? org.apache.flink.table.api.TableException: Processing-time temporal join is not supported yet. sql?????????????????????????????????????????????? create view visioned_table as select user_id, event from (select user_id, event, row_number() over(partition by user_id order by event_time desc) as rn from kafka_table1 )ta where rn=1; select t1.*,t2.* from mvp_rtdwd_event_app_quit t1 join visioned_table FOR SYSTEM_TIME AS OF t1.proc_time AS t2 on t1.user_id=t2.user_id where t1.user_id is not null
