Re: Production Deployments

2017-05-13 Thread Samuel Doyle
/projects/flink/flink-docs-release-1.2/setup/kubernetes.html > > I’m not aware of a preference for any one cluster manager. YARN has been > around the longest but we want Flink to run everywhere in the cloud and in > the enterprise. > > > On May 12, 2017, at 7:29 PM, Sa

Production Deployments

2017-05-12 Thread Samuel Doyle
Is there some documentation describing best practices regarding production deployments specifically recommended configuration and setup? From what I have seen, it appears that YARN is the suggested way to handle a clustered deployment. I am not familiar with YARN so I am hoping that after coming u

Re: Joining on multiple row values produced by TableFunction

2017-05-09 Thread Samuel Doyle
ache/flink/table/api/scala/stream/sql/OverWindowITCase.scala > > 2017-05-09 21:59 GMT+02:00 Samuel Doyle : > >> Is it possible to define windows in such a way that I can use straight >> sql like with the table environment vs the sql 'like' syntax you use when >> u

Re: Joining on multiple row values produced by TableFunction

2017-05-09 Thread Samuel Doyle
Is it possible to define windows in such a way that I can use straight sql like with the table environment vs the sql 'like' syntax you use when using the table api? My project is based off Java. Thanks On Tue, May 9, 2017 at 10:34 AM Samuel Doyle wrote: > I was able to get it

Re: Joining on multiple row values produced by TableFunction

2017-05-09 Thread Samuel Doyle
h are called fields). > If that's not the case, can you provide more information? > > - Is there an error message? > - Yes: what's the error message > - No: what's the output and what would you expect? > - Is this for batch or streaming? > > Thanks, Fabian

Joining on multiple row values produced by TableFunction

2017-05-08 Thread Samuel Doyle
I want to do something like the following .join("fields(fields) as (name, content)") .where("text = 'password for user' && name='text' && !content.like('%accepted%') && name='appname' && content.like('%hostd%')") Fields collects 4 rows in this case which contain those valu