Thanks will pull and rebuild container. Will get back after test. From: Kyle Weaver <kcwea...@google.com> Sent: 28 May 2020 17:02 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>. 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@01D63511.FF44BF60][cid:image002.png@01D63511.FF44BF60]
