Stateful Functions are in another repository. Take a look at device and phone packages. Deployment breaks into 2 parts: 1. Deploying your dataflow job (just a Flink cluster with your job running) 2. Deploying a service that implements remote functions as an ordinary service
Best, Tymur Yarosh On 1 Jun 2022, 05:51 +0300, Himanshu Sareen <himanshusar...@outlook.com>, wrote: > Tanks Tymur, for the pointers. > > > I followed the GitHub link and got the understanding on how to define and > configure Remote Functions with Datastream Api > > However, I need help in understanding the following: > > 1. I didn't find Stateful function definition and server code. > 2. How should we deploy Stateful Function code > > If you can please help with pointers on Deployment of Stateful function code > and the GitHub code. > > Regards > Himanshu > From: Tymur Yarosh <ti.yar...@gmail.com> > Sent: Wednesday, May 25, 2022 9:53:20 PM > To: user@flink.apache.org <user@flink.apache.org>; Himanshu Sareen > <himanshusar...@outlook.com> > Subject: Re: Flink DataStream and remote Stateful Functions interoperability > > Hi Himanshu, > > The short answer is you should configure Stateful Functions in your job. Here > is an example > https://github.com/f1xmAn/era-locator/blob/34dc4f77539195876124fe604cf64c61ced4e5da/src/main/java/com/github/f1xman/era/StreamingJob.java#L68. > > Check out this article on Flink DataStream and Stateful Functions > interoperability > https://medium.com/devoops-and-universe/realtime-detection-of-russian-crypto-phone-era-with-flink-datastream-and-stateful-functions-e77794fedc2a. > > Best, > Tymur Yarosh > On 24 May 2022, 21:16 +0300, Himanshu Sareen <himanshusar...@outlook.com>, > wrote: > > Team, > > > > I'm working on a POC where our existing Stateful Functions ( remote ) can > > interact with Datastream API. > > https://nightlies.apache.org/flink/flink-statefun-docs-release-3.2/docs/sdk/flink-datastream/ > > > > I started Flink cluster - ./bin/start-cluster.sh > > Then I submitted the .jar to Flink. > > > > However, on submitting only Embedded function is called by Datastream code. > > > > I'm unable to invoke stateful functions as module.yaml is not loaded. > > > > Can someone help me in understanding how can we deploy Stateful function > > code (module.yaml) and Datastream api code parllely on Flink cluster. > > > > > > Regards > > Himanshu > >
