2.21.0 should be available now: https://hub.docker.com/layers/apache/beam_flink1.9_job_server/2.21.0/images/sha256-eeac6dd4571794a8f985e9967fa0c1522aa56a28b5b0a0a34490a600065f096d?context=explore
On Thu, May 28, 2020 at 7:27 AM Ashish Raghav <ashish.rag...@corecompete.com> wrote: > Hi Kyle, > > > > The Latest Version available on docker hub is 2.20.0 > > > > > > *From:* Kyle Weaver <kcwea...@google.com> > *Sent:* 28 May 2020 16:51 > *To:* user@beam.apache.org > *Subject:* Re: Issue while submitting python beam pipeline on flink - > local > > > > *EXTERNAL EMAIL* > > Do not click links or open attachments unless you recognise the sender and > know the content is safe. Report suspicious email to > info...@corecompete.com. > > > > 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* > > > >
