RE: Issue while submitting python beam pipeline on flink - local

2020-06-07 Thread Ashish Raghav
Thanks . Will try From: Kyle Weaver Sent: 05 June 2020 20:46 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

Re: Issue while submitting python beam pipeline on flink - local

2020-06-05 Thread Kyle Weaver
ingCache.get(LocalCache.java:4958) > at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4964) > ... 12 more > Caused by: java.io.IOException: error=2, No such file or directory > at java

RE: Issue while submitting python beam pipeline on flink - local

2020-06-05 Thread Ashish Raghav
t(ProcessBuilder.java:1029) ... 26 more Ashish Raghav | DE Core Compete | ashish.rag...@corecompete.com Accelerating Cloud Analytics -Original Message----- From: Ashish Raghav Sent: 01 June 2020 16:48 To: user@beam.apache.org Subject: RE: Issue while submitting python beam pipeline on flink - loc

RE: Issue while submitting python beam pipeline on flink - local

2020-06-01 Thread Ashish Raghav
/documentation/runners/flink/#dependencies -Original Message- From: Maximilian Michels Sent: 01 June 2020 15:37 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

Re: Issue while submitting python beam pipeline on flink - local

2020-06-01 Thread Maximilian Michels
stions/59429897/beam-running-on-flink-with-python-sdk-and-using-google-cloud-storage-for-artifac > > But it seems, there are other things to do to fix this. > >   > > Please suggest. > >   > >   > > *From:*Ashish Raghav > *Sent:* 30 May 2020 10:12 >

RE: Issue while submitting python beam pipeline on flink - local

2020-05-31 Thread Ashish Raghav
ailto:kcwea...@google.com>> Sent: Thursday, May 28, 2020, 10:34 PM 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 kn

Re: Issue while submitting python beam pipeline on flink - local

2020-05-29 Thread Ashish Raghav
: 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. > You are using the LOOPBACK environm

Re: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Kyle Weaver
> You are using the LOOPBACK environment which requires that the Flink > cluster can connect back to your local machine. Since the loopback > environment by defaults binds to localhost that should not be possible. On the Flink runner page, we recommend using --net=host to avoid the kinds of networ

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
File "C:\Users\ashish.raghav\Desktop\projects\beam-venv\lib\site-packages\grpc\_utilities.py", line 86, in _block raise grpc.FutureTimeoutError() grpc.FutureTimeoutError -Original Message----- From: Ashish Raghav Sent: 28 May 2020 18:22 To: user@beam.apache.org Subject: RE: Issue while submittin

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
Ok, will try that. -Original Message- From: Maximilian Michels Sent: 28 May 2020 18:20 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

Re: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Maximilian Michels
st_generator()) > >   File > "C:\Users\ashish.raghav\Desktop\projects\test-flink\.venv\lib\site-packages\grpc\_channel.py", > line 1011, in __call__ > >     return _end_unary_response_blocking(state, call, False, None) > >   File > "C:\Users\ashi

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
lt;_InactiveRpcError of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "failed to connect to all addresses" debug_error_string = "{"created":"@1590667588.14600","description":"Failed to pick subch

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
Ok. Will test with latest version. From: Kyle Weaver 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

Re: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Kyle Weaver
27 AM Ashish Raghav < > ashish.rag...@corecompete.com> wrote: > >> Hi Kyle, >> >> >> >> The Latest Version available on docker hub is 2.20.0 >> >> >> >> >> >> *From:* Kyle Weaver >> *Sent:* 28 May 2020 16:51 >

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
Thanks will pull and rebuild container. Will get back after test. From: Kyle Weaver 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

Re: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Kyle Weaver
Latest Version available on docker hub is 2.20.0 > > > > > > *From:* Kyle Weaver > *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 clic

RE: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Ashish Raghav
Hi Kyle, The Latest Version available on docker hub is 2.20.0 From: Kyle Weaver 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

Re: Issue while submitting python beam pipeline on flink - local

2020-05-28 Thread Kyle Weaver
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 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 Pip