Ok. Will test with latest version. From: Kyle Weaver <kcwea...@google.com> Sent: 28 May 2020 17:03 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>. Oh, I see the issue. The documentation you were looking at might contain an outdated reference to the apachebeam repo on Docker hub. We have migrated all Docker images to the apache top-level repository. So instead of apachebeam/flink1.9_job_server, you should use apache/beam_flink1.9_job_server. On Thu, May 28, 2020 at 7:31 AM Kyle Weaver <kcwea...@google.com<mailto:kcwea...@google.com>> wrote: 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<mailto:ashish.rag...@corecompete.com>> wrote: Hi Kyle, The Latest Version available on docker hub is 2.20.0 From: Kyle Weaver <kcwea...@google.com<mailto:kcwea...@google.com>> Sent: 28 May 2020 16:51 To: user@beam.apache.org<mailto: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@01D63512.3A0F8F30][cid:image002.png@01D63512.3A0F8F30]
