Hi, Do you use Flink operator or manually deployed session cluster ?
Thanks On Fri, Feb 3, 2023, 4:32 AM P Singh <bigdatadevelop...@gmail.com> wrote: > Hi Team, > > I have set up a flink cluster on GKE and am trying to submit a beam > pipeline with below options. I was able to run this on a local machine but > I don't understand what would be the environment_config? What should I do? > what to put here instead of localhost:50000 > > Please help. > options = PipelineOptions([ > "--runner=FlinkRunner", > "--flink_version=1.14", > "--flink_master=localhost:8081", > "--environment_type=EXTERNAL", #EXTERNAL > "--environment_config=localhost:50000", > ]) >
