Re: Job manager - Zookeeper HA

2018-03-19 Thread Liangfei Su
You're right. It's job-manager read and distribute jar files. If you are using HDFS, you should be able to check no connection from TM to hadoop. On Mon, Mar 19, 2018 at 9:36 PM, Sampath Bhat wrote: > Hello > > I'm configuring flink cluster with Zookeeper for high availability for Job > managers

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

2017-06-13 Thread Liangfei Su
+1 for the feature. Myself was a user of Siddhi, this is pretty user friendly feature to provide to user. On Tue, Jun 13, 2017 at 3:09 PM, Dian Fu wrote: > Hi Yueting & Dawid Wysakowicz, > > Very glad that you're interested in this feature and you're definitely > welcome to join this work and al

Re: [jira] [Updated] (FLINK-6126) Yet another conflict : guava

2017-03-20 Thread Liangfei Su
her user. > > > On Mon, Mar 20, 2017 at 2:36 PM, Aljoscha Krettek > wrote: > > So it is resolved now? Thanks for letting us know! > >> On 20 Mar 2017, at 12:55, Liangfei Su wrote: > >> > >> Well...Comments added. > >> > >

Re: [jira] [Updated] (FLINK-6126) Yet another conflict : guava

2017-03-20 Thread Liangfei Su
f elastic search(guava 18) and the packaged ones(should be the ones from hadoop related) On Mon, Mar 20, 2017 at 7:04 PM, Liangfei Su wrote: > Another finding that it looks most of these kinds of conflict comes from > the dependency to hadoop/hbase (by using mvn dependency to check). >

Re: [jira] [Updated] (FLINK-6126) Yet another conflict : guava

2017-03-20 Thread Liangfei Su
, Liangfei Su wrote: > Hi, > > I try to write some user function to write elastic search, my project > comes with elastic search 2.3.5 (which is the same to flink connectors > elastic search). But i'm seeing be exception that recorded in the below > JIRA, by enabling the java

Fwd: [jira] [Updated] (FLINK-6126) Yet another conflict : guava

2017-03-20 Thread Liangfei Su
Hi, I try to write some user function to write elastic search, my project comes with elastic search 2.3.5 (which is the same to flink connectors elastic search). But i'm seeing be exception that recorded in the below JIRA, by enabling the java -version:class, it show it's the guava dependency issu

Re: Question: RemoteStreamEnvironment submit in detach mode.

2017-03-15 Thread Liangfei Su
gt; BR, Evgeny > > [1] - https://issues.apache.org/jira/browse/FLINK-2313 > [2] - https://issues.apache.org/jira/browse/FLINK-4272 > [3] - https://github.com/apache/flink/pull/2732 > > -Original Message- > From: Liangfei Su [mailto:suliang...@gmail.com] > Sent: Wednesd

Question: RemoteStreamEnvironment submit in detach mode.

2017-03-15 Thread Liangfei Su
Hi, I get a question when try to submit a graph to a remote stream RemoteStreamEnvironment in detach mode. >From the client API, it looks when use call execute(). User doesn't have a way to control whether run in detach mode or not. Since it's the RemoteStreamEnvironment create a StandaloneClust