Re: Flink DataStream and remote Stateful Functions interoperability

2022-06-01 Thread Tymur Yarosh
h > Sent: Wednesday, May 25, 2022 9:53:20 PM > To: user@flink.apache.org ; Himanshu Sareen > > Subject: Re: Flink DataStream and remote Stateful Functions interoperability > > Hi Himanshu, > > The short answer is you should configure Stateful Functions

Re: Flink DataStream and remote Stateful Functions interoperability

2022-05-31 Thread Himanshu Sareen
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/f1xma

Re: Flink DataStream and remote Stateful Functions interoperability

2022-05-25 Thread Tymur Yarosh
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

Flink DataStream and remote Stateful Functions interoperability

2022-05-24 Thread Himanshu Sareen
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. Howeve