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]> 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]> wrote:
>
>> Hi Kyle,
>>
>>
>>
>> The Latest Version available on docker hub is 2.20.0
>>
>>
>>
>>
>>
>> *From:* Kyle Weaver <[email protected]>
>> *Sent:* 28 May 2020 16:51
>> *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].
>>
>>
>>
>> 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]> 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/>* | [email protected]
>> <[email protected]>
>>
>> *Accelerating Cloud Analytics*
>>
>>
>>
>>

Reply via email to