Re:Re: SQL层应用维表join jdbc的时候，请问怎么动态感知维表数据的变化呢？

Posted by on Jan 04, 2020; 5:55am
URL: http://apache-flink.370.s1.nabble.com/SQL-join-jdbc-tp1393p1395.html



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" <[hidden email]> 写道：

>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
>
>刘世民 <[hidden email]> 于2020年1月4日周六 上午11:27写道：
>
>> hi~
>> 如图所示，在做kafka和jdbc
>> join的时候，jdbc数据全量加载并为Finished状态，这种情况下请问怎么感知jdbc表的数据更新呢？还是我哪里的配置不对，还请赐教
>>
>> 小白敬上~
>>
>>
>>
>>
>
>
>--
>
>Benchao Li
>School of Electronics Engineering and Computer Science, Peking University
>Tel:[phone]
>Email: [hidden email]; [hidden email]