Hi Ashish, can you check to make sure apachebeam/flink1.9_job_server is also on version 2.21.0?
On Thu, May 28, 2020 at 7:13 AM Ashish Raghav <ashish.rag...@corecompete.com> wrote: > Hello Guys , > > > > I am trying to run a python beam pipeline on flink. I am trying to run > apache_beam.examples.wordcount_minimal but with Pipelineoptions as > > "--runner=PortableRunner", > "--job_endpoint=192.168.99.100:8099", > "--environment_type=LOOPBACK", > > > > I have a apachebeam/flink1.9_job_server running on local container. > Whenever I submit the job , I get errors ( attached the log).When I run it > with DirectRunner, the code runs fine though. > > > > versions: > > Apache Beam SDK=2.21.0 > python=3.7.6 > > > > I have followed all instruction from the apache beam UI but I seem to have > hit a roadblock here. Please suggest. > > > > Please let me know if any other information is required. > > > > *Ashish Raghav | DE* > > *Core Compete <https://corecompete.com/>* | ashish.rag...@corecompete.com > <adwait.th...@corecompete.com> > > *Accelerating Cloud Analytics* > > >
