??????????flink-sql????mysql??????join??ddl??dml??????

???????? Fri, 11 Oct 2019 18:17:26 -0700

select *, PROCTIME() as proctime from source ??????SQL parse failed. 
Encountered ")" at ...&nbsp;
PROCTIME ()??????????????????



 
---????????---
??????: "Jark Wu"<[email protected]&gt;
????????: 2019??10??11??(??????) ????7:23
??????: "user-zh"<[email protected]&gt;;
????: Re: ????flink-sql????mysql??????join??ddl??dml??????


???? o.proctime ?? DDL ?????????????????????????????????? query ???????? 
proctime ??????

"select ...
&nbsp;from (select *, PROCTIME() as proctime from source)"

On Fri, 11 Oct 2019 at 18:45, ???????? <[email protected]&gt; wrote:

&gt; ????sql ddl????????o.proctime????
&gt;
&gt;
&gt;
&gt; ---????????---
&gt; ??????: "Jark Wu"<[email protected]&amp;gt;
&gt; ????????: 2019??9??29??(??????) ????11:42
&gt; ??????: "user-zh"<[email protected]&amp;gt;;
&gt; ????: Re: ????flink-sql????mysql??????join??ddl??dml??????
&gt;
&gt;
&gt; Hi,
&gt;
&gt; mysql ?????? DDL ?? ????/?????? ?? DDL ?????????? ???????????? DDL 
????????rates ?? flink sql ????????????
&gt; source ???????? sink????????????????
&gt;
&gt; CREATE TABLE rates (
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; currency VARCHAR,
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; rate BIGINT
&gt; ) WITH (
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; 'connector.type' = 'jdbc', -- ???? jdbc 
connector
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; 'connector.url' =
&gt; 'jdbc:mysql://localhost:3306/flink-test', -- jdbc url
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; 'connector.table' = 'rates', -- ????
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; 'connector.username' = 'root', -- ??????
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp; 'connector.password' = '123456', -- ????
&gt; )
&gt;
&gt; ???????????????????????????????????? temporal join ????????????
&gt;
&gt; SELECT
&gt; &amp;nbsp; o.amout, o.currency, r.rate, o.amount * r.rate
&gt; FROM
&gt; &amp;nbsp; Orders AS o
&gt; &amp;nbsp; JOIN rates FOR SYSTEM_TIME AS OF o.proctime AS r
&gt; &amp;nbsp; ON r.currency = o.currency
&gt;
&gt; &amp;nbsp;???????? join????????????????????
&gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/joins.html#join-with-a-temporal-table
&gt;
&gt;
&gt;
&gt;
&gt; On Fri, 27 Sep 2019 at 14:12, yelun <[email protected]&amp;gt; wrote:
&gt;
&gt; &amp;gt; Hi????????????
&gt; &amp;gt;
&gt; &amp;gt; 
??????????flink-sql????mysql??????join??ddl??dml????????demo????????????????????????

??????????flink-sql????mysql??????join??ddl??dml??????

回复