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> >> >> >>
