Re: Official flink java client

2021-04-23 Thread gaurav kulkarni
nd Date:Fri Apr 23 16:10:05 2021Recipients:Yun Gao CC:gaurav kulkarni , User Subject:Re: Re: Official flink java client Obviously I could rewrite a java client from scratch that interface with the provided REST API but why if I can reuse something already existing?Usually I interface with REST

Re: Re: Re: Official flink java client

2021-04-23 Thread Flavio Pompermaier
might need to be careful when > upgrading. > > Best, > Yun > > > --Original Mail -- > *Sender:*Flavio Pompermaier > *Send Date:*Fri Apr 23 16:10:05 2021 > *Recipients:*Yun Gao > *CC:*gaurav kulkarni , User < > user@flink.apache.org&g

Re: Re: Re: Official flink java client

2021-04-23 Thread Yun Gao
16:10:05 2021 Recipients:Yun Gao CC:gaurav kulkarni , User Subject:Re: Re: Official flink java client Obviously I could rewrite a java client from scratch that interface with the provided REST API but why if I can reuse something already existing? Usually I interface with REST API using auto

Re: Re: Official flink java client

2021-04-23 Thread Flavio Pompermaier
*Send Date:*Fri Apr 23 15:25:55 2021 > *Recipients:*Yun Gao > *CC:*gaurav kulkarni , User < > user@flink.apache.org> > *Subject:*Re: Official flink java client > >> I also interface to Flink clusters using REST in order to avoid many >> annoying problems (due

Re: Re: Official flink java client

2021-04-23 Thread Yun Gao
Hi Falvio, Very thanks for the explanation, may be another option is to have a look at the http rest API[1] ? Flink provides official http api to submit jar jobs and query job status, and they might be able to help. Best, Yun [1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/rest

Re: Official flink java client

2021-04-23 Thread Flavio Pompermaier
I also interface to Flink clusters using REST in order to avoid many annoying problems (due to dependency conflicts, classpath or env variables). I use an extended version of the RestClusterClient that you can reuse if you want to. It is available at [1] and it add some missing methods to the defau

Re: Official flink java client

2021-04-22 Thread Yun Gao
Hi gaurav, Logicall Flink client is bear inside the StreamExecutionEnvironment, and users could use the StreamExecutionEnvironment to execute their jobs. Could you share more about why you want to directly use the client? Best, Yun --Original Mail -- Sende