Re: Flink Table 1.5-SNAPSHOT

2018-02-24 Thread Shuyi Chen
Maybe you can explain a bit more on what you need. But here is the link to the jar for your convenience, https://drive.google.com/file/d/0BwG71AtfYG0aZk04MHNSMDZiZTlkbUh0dXktMXphZ1c3YTdR/view?usp=sharing. Just rename it and remove the .tmp suffix. On Sat, Feb 24, 2018 at 9:40 AM, Pavel Ciorba wro

Flink Table 1.5-SNAPSHOT

2018-02-24 Thread Pavel Ciorba
Hi everyone! I want to test the nonWindowInnerJoin API. Could anyone share the flink-table 1.5-SNAPSHOT jar ? (dropbox link etc.) I've tried to build the flink-table myself using *mvn clean install *but when I import it in a Gradle project it is unresolved for some reason. I'd be glad if someon

[jira] [Created] (FLINK-8775) Make shut down of MiniCluster non blocking

2018-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8775: Summary: Make shut down of MiniCluster non blocking Key: FLINK-8775 URL: https://issues.apache.org/jira/browse/FLINK-8775 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-8774) Make shut down of ResourceManagerRunner non blocking

2018-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8774: Summary: Make shut down of ResourceManagerRunner non blocking Key: FLINK-8774 URL: https://issues.apache.org/jira/browse/FLINK-8774 Project: Flink Issue Type

[jira] [Created] (FLINK-8773) Make shut down of JobManagerRunner non blocking

2018-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8773: Summary: Make shut down of JobManagerRunner non blocking Key: FLINK-8773 URL: https://issues.apache.org/jira/browse/FLINK-8773 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-8772) FlinkKafkaConsumerBase partitions discover missing a log parameter

2018-02-24 Thread Matrix42 (JIRA)
Matrix42 created FLINK-8772: --- Summary: FlinkKafkaConsumerBase partitions discover missing a log parameter Key: FLINK-8772 URL: https://issues.apache.org/jira/browse/FLINK-8772 Project: Flink Issue

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 to flink and I have a quest

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

2018-02-24 Thread Hequn Cheng
Hi, udtf variables should not be empty, otherwise calcite failed to convert the join to an correlate. Best, Hequn 2018-02-23 0:34 GMT+08:00 叶振宝 <827295...@qq.com>: > Hey, I am new to flink and I have a question and want to see if anyone can > help here. > > How to use Dimension table in Flink Ta

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

2018-02-24 Thread 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 to flink and I have a question and want to see if anyone can > help here. > > How to use Dimension table in Flin