Re: How to use Dimension table in Flink TableAPI with StreamExecutionEnvironment ?

2018-02-27 Thread Fabian Hueske
Hi, Liu and Hequn are right. You need to pass at least one parameter into the table function, i.e., select t.col_1 from test t left join lateral table(dim_test(SOME_ATTRIBUTE)) b on true Best, Fabian 2018-02-24 13:24 GMT+01:00 ZhenBao Ye : > hi,i was use 1.4.0。 > >

Re: How to use Dimension table in Flink TableAPI with StreamExecutionEnvironment ?

2018-02-24 Thread ZhenBao Ye
hi,i was use 1.4.0。 Yezhenbao > 在 2018年2月24日,17:55,Renjie Liu 写道: > > Hi, according to flink doc, it seems that you need to pass at least one > argument into the table function. > >> On Fri, Feb 23, 2018 at 12:35 AM 叶振宝 <827295...@qq.com> wrote: >> >> Hey, I am new