Hi George, Here is some documentation about how to deploy a stateful function job [1]. In a nutshell, you need to deploy a Flink cluster on which you can run the stateful function job. This can either happen before (e.g. by spawning a session cluster on K8s [2]) or you can combine your job into a Docker image [3] which you can use to spin up a cluster.
[1] https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/deployment-and-operations/packaging.html#packaging-for-deployment [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/native_kubernetes.html [3] https://hub.docker.com/r/ververica/flink-statefun Cheers, Till On Mon, Nov 23, 2020 at 3:39 PM George Costea <rgcos...@gmail.com> wrote: > Sorry. Forgot to reply to all. > > On Sun, Nov 22, 2020 at 9:24 PM George Costea <rgcos...@gmail.com> wrote: > > > > Hi Xingbo, > > > > I’m interested in using stateful functions to build an application on > Kubernetes. Don’t I need to deploy the flink cluster on Kubernetes first > before deploying my stateful functions? > > > > Thanks, > > George > > > > On Sun, Nov 22, 2020 at 9:01 PM Xingbo Huang <hxbks...@gmail.com> wrote: > >> > >> Hi, George > >> > >> >>> Is zookeeper needed to run the flink cluster? > >> No. zookeeper is needed by the kafka. > >> > >> >>> Or is it just the master and worker deployments? > >> This example uses the kafka connector, so some kafka and zookeeper > configurations are added. > >> > >> >>> Is the fink cluster included in the master and worker stateful > functions? > >> In fact, I don’t really understand how this problem is related to > stateful functions. > >> > >> Best, > >> Xingbo > >> > >> George Costea <rgcos...@gmail.com> 于2020年11月21日周六 上午11:09写道： > >>> > >>> I looked at that. > >>> > >>> The docker-compose file for the greeter example deploys a worker, a > >>> master, zookeeper, and kafka. Is zookeeper needed to run the flink > >>> cluster? Or is it just the master and worker deployments? Is the > >>> fink cluster included in the master and worker stateful functions? > >>> > >>> Thanks in advance. > >>> > >>> On Fri, Nov 20, 2020 at 9:32 PM Xingbo Huang <hxbks...@gmail.com> > wrote: > >>> > > >>> > Hi George, > >>> > Have you referred to the official document[1]? > >>> > > >>> > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html > >>> > > >>> > Best, > >>> > Xingbo > >>> > > >>> > 在 2020年11月21日星期六，George Costea <rgcos...@gmail.com> 写道： > >>> > > Hi there, > >>> > > > >>> > > Is there an example of how to deploy a flink cluster on Kubernetes? > >>> > > I'd like to deploy the flink cluster, a kafka-broker, and then the > >>> > > greeter example to give it a try. > >>> > > > >>> > > Thanks, > >>> > > George > >>> > > >
