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<mailto: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<mailto: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<http://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<mailto:adwait.th...@corecompete.com> Accelerating Cloud Analytics [cid:image001.jpg@01D63511.232C99D0][cid:image002.png@01D63511.232C99D0]
