Fwd: Running a Beam Pipeline on GCP Dataproc Flink Cluster

2020-02-08 Thread Paweł Kordek
From: Paweł Kordek Sent: Saturday, February 8, 2020, 08:48 To: Xander Song Subject: Re: Running a Beam Pipeline on GCP Dataproc Flink Cluster It's because 1.9.1 is no longer hosted under this particular link you can change to 1.9.2. BTW this link is just an exam

Re: Problem with updating beam SDK

2020-02-08 Thread vivek chaurasiya
Can someone comment here? On Fri, Feb 7, 2020, 11:52 PM vivek chaurasiya wrote: > Hi team, > > We had beam SDKs 2.5 running on AWS-EMR Spark distribution 5.17. > > Essentially our beam code was just reading bunch of files from GCS and > pushing to ElasticSearch in AWS using beam's class ElasticS

Re: Running Beam on Flink

2020-02-08 Thread Xander Song
Do you have any suggestions for addressing this issue? I am unsure of what to try next. On Fri, Feb 7, 2020 at 5:55 PM Ankur Goenka wrote: > That seems to be a problem. > > When I try the command, I get > > $ telnet localhost 8099 > Trying ::1... > Connected to localhost. > Escape character is '