Re: Dynamic Rule Evaluation in Flink

2018-07-03 Thread Chuanlei Ni
> > >1. Since the CoFlatMap function works on a single event, how do we >evaluate rules that require aggregations across events. (Match rule if more >than 5 A events happen) >2. Since the CoFlatMap function works on a single event, how do we >evaluate rules that require pattern

Re: The program didn't contain a Flink job

2018-07-03 Thread Chuanlei Ni
I really interesting in making `ClusterClient` be used as multiple-instance in a jvm, because we need submit job in a long running process. I create a jira for this problem. https://issues.apache.org/jira/browse/FLINK-9710 eSKa 于2018年7月3日周二 下午4:20写道: > Yes - it seems that main method returns s

Re: Regarding external metastore like HIVE

2018-07-03 Thread Chuanlei Ni
@ashwin I cannot find the documention about `metastore` Could you give the reference? Ashwin Sinha 于2018年7月3日周二 下午4:08写道: > By metastore we mean catalog where table information is stored. > > On Tue 3 Jul, 2018, 13:23 Chesnay Schepler, wrote: > >> What do you mean with "Metastore"? Are you re

Re: The program didn't contain a Flink job

2018-07-03 Thread Chuanlei Ni
HI, @chesnay I read the code of `ClusterClient`, and have not found the `static` field. So why cannot be used in the same jvm? (we also use `ClusterCLient` this way, so we really care about this feature) eSKa 于2018年7月3日周二 下午4:00写道: > Yes - we are submitting jobs one by one. > How can we change