Ok. Will test with latest version. From: Kyle Weaver <[email protected]> Sent: 28 May 2020 17:03 To: [email protected] 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 [email protected]<mailto:[email protected]>. 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 <[email protected]<mailto:[email protected]>> 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 <[email protected]<mailto:[email protected]>> wrote: Hi Kyle, The Latest Version available on docker hub is 2.20.0 From: Kyle Weaver <[email protected]<mailto:[email protected]>> Sent: 28 May 2020 16:51 To: [email protected]<mailto:[email protected]> 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 [email protected]<mailto:[email protected]>. 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 <[email protected]<mailto:[email protected]>> 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/> | [email protected]<mailto:[email protected]> Accelerating Cloud Analytics [cid:[email protected]][cid:[email protected]]
