Re: How to ensure that job is restored from savepoint when using Flink SQL

2020-07-08 Thread shadowell
Hi Fabian, Thanks for your reply, it helps a lot. Best Regards, Jie | | shadowell | | shadow...@126.com | 签名由网易邮箱大师定制 On 7/8/2020 18:17,Fabian Hueske wrote: Hi Jie, The auto-ID generation is not done by the SQL translation component but on a lower level, i.e., it's indepe

Re: How to ensure that job is restored from savepoint when using Flink SQL

2020-07-07 Thread shadowell
ads to inaccurate calculation results. I wonder if my understanding is correct. Thanks~ Jie | | shadowell | | shadow...@126.com | 签名由网易邮箱大师定制 On 7/7/2020 17:23,Fabian Hueske wrote: Hi Jie Feng, As you said, Flink translates SQL queries into streaming programs with auto-generated operator IDs

How to ensure that job is restored from savepoint when using Flink SQL

2020-07-06 Thread shadowell
? Thanks~ Jie Feng | | shadowell | | shadow...@126.com | 签名由网易邮箱大师定制

Flink SQL join usecase

2020-05-12 Thread shadowell
Hi, I am new to Flink SQL, I want to know whether Flink SQL(Flink-1.10) supports the following join syntax: ``` select a.id, a.col_1, b.col_1, c.col_1 from topic_a a inner join topic_b b on a.id = b.id left join topic_c c on a.id = c.id and a.col_1 = c.col_1 and b.col_