hi Benchao,
我明白你的意思,我认真在看官方文档学习flink相关知识,知道目前temporal table join只支持processing-time, 但是当我使用给出的join sql例子写法时,报出这个异常,[ Column 'proctime' not found in table 'o' ],这个问题是传统的通过别名 [ o ]去找 [ o ]表中的proctime列,但是显然表中是没有proctime列的, 请问我该怎么解决这个问题呢?我应该去了解熟悉哪方面的知识?Mysql支持ANSI-2011标准的Temporal table语义吧,请赐教~ 祝好 在 2020-01-04 12:10:34,"Benchao Li" <libenc...@gmail.com> 写道: >hi 世民, > >邮件列表里不支持直接发送图片,你可以用一些图床工具来发送图片。 >根据你的描述,我猜测你应该是join维表的语法写的不对,写成了普通的join的方式。这种情况下,会把jdbc的表解析成`JDBCInputFormat`,一次性读取全部数据。 >维表join的SQL写法如下所示: > >SELECT > o.amout, o.currency, r.rate, o.amount * r.rateFROM > Orders AS o* JOIN LatestRates FOR SYSTEM_TIME AS OF o.proctime AS r >* ON r.currency = o.currency > >详细内容可以参考文档: >https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sql.html#joins > >刘世民 <amen...@163.com> 于2020年1月4日周六 上午11:27写道: > >> hi~ >> 如图所示,在做kafka和jdbc >> join的时候,jdbc数据全量加载并为Finished状态,这种情况下请问怎么感知jdbc表的数据更新呢?还是我哪里的配置不对,还请赐教 >> >> 小白敬上~ >> >> >> >> > > >-- > >Benchao Li >School of Electronics Engineering and Computer Science, Peking University >Tel:+86-15650713730 >Email: libenc...@gmail.com; libenc...@pku.edu.cn