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 generated clients (if APIs are exposed via Swagger or OpenApi). If that's not an option, writing a REST client from scratch is something I try to avoid as much as I can..
Best, Flavio On Fri, Apr 23, 2021 at 9:55 AM Yun Gao <yungao...@aliyun.com> wrote: > 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_api.html > > ------------------Original Mail ------------------ > *Sender:*Flavio Pompermaier <pomperma...@okkam.it> > *Send Date:*Fri Apr 23 15:25:55 2021 > *Recipients:*Yun Gao <yungao...@aliyun.com> > *CC:*gaurav kulkarni <kulkarnigaur...@yahoo.com>, 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 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 default >> Flink version (I also had to copy that class and modify the visibility of >> some field in order to enable the extension). >> Officially the Flink RestClusterClient is meant to be used for internal >> use only but it actually work very well. >> >> Best, >> Flavio >> >> [1] >> https://github.com/fpompermaier/flink-job-server/blob/main/flink-rest-client/src/main/java/org/apache/flink/client/program/rest/RestClusterClientExtended.java >> >> On Fri, Apr 23, 2021 at 5:10 AM Yun Gao <yungao...@aliyun.com> wrote: >> >>> 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 ------------------ >>> *Sender:*gaurav kulkarni <kulkarnigaur...@yahoo.com> >>> *Send Date:*Fri Apr 23 10:14:08 2021 >>> *Recipients:*User <user@flink.apache.org> >>> *Subject:*Official flink java client >>> >>>> Hi, >>>> >>>> Is there any official flink client in java that's available? I came >>>> across RestClusterClient >>>> <https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/client/program/rest/RestClusterClient.html>, >>>> but I am not sure if its official >>>> <https://stackoverflow.com/questions/56079788/run-already-deployed-job-on-flink-cluster-using-restclusterclient>. >>>> I can create my own client, but just wanted to check if there is anything >>>> official available already that I can leverage. >>>> >>>> Thanks, >>>> Gaurav >>>> >>>> Run already deployed job on Flink Cluster using RestClusterClient >>>> >>>> I am trying to run already deployed job on Flink Cluster using Rest >>>> request.I had success using a simple rest ... >>>> >>>> <https://stackoverflow.com/questions/56079788/run-already-deployed-job-on-flink-cluster-using-restclusterclient> >>>> >>>> >>>>
