Re: Running Flink jobs directly from Eclipse

2016-04-06 Thread Christophe Salperwyck
ere you can run the flink command from, and doesn't > mention that you can run the job programmatically instead of using the CLI. > > > > *From: *Christophe Salperwyck > *Date: *Wednesday, April 6, 2016 at 1:24 PM > *To: * > *Subject: *Re: Running Flink jobs directly from Ecl

RE: Running Flink jobs directly from Eclipse

2016-04-06 Thread Serhiy Boychenko
...@gmail.com] Sent: 06 April 2016 13:41 To: user@flink.apache.org Subject: Re: Running Flink jobs directly from Eclipse For me it was taking the local jar and uploading it into the cluster. 2016-04-06 13:16 GMT+02:00 Shannon Carey mailto:sca...@expedia.com>>: Thanks for the info! It is

Re: Running Flink jobs directly from Eclipse

2016-04-06 Thread Christophe Salperwyck
grammatically instead of using the CLI. > > From: Christophe Salperwyck > Date: Wednesday, April 6, 2016 at 1:24 PM > To: > Subject: Re: Running Flink jobs directly from Eclipse > > From my side I was starting the YARN session from the cluster: > flink-0.10.1/bin/yarn-sessi

Re: Running Flink jobs directly from Eclipse

2016-04-06 Thread Shannon Carey
16 at 1:24 PM To: mailto:user@flink.apache.org>> Subject: Re: Running Flink jobs directly from Eclipse From my side I was starting the YARN session from the cluster: flink-0.10.1/bin/yarn-session.sh -n 64 -s 4 -jm 4096 -tm 4096 Then getting the IP/port from the WebUI and then from Eclipse: Ex

Re: Running Flink jobs directly from Eclipse

2016-04-06 Thread Christophe Salperwyck
>From my side I was starting the YARN session from the cluster: flink-0.10.1/bin/yarn-session.sh -n 64 -s 4 -jm 4096 -tm 4096 Then getting the IP/port from the WebUI and then from Eclipse: ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("xx.xx.xx.xx", 40631, "target/FlinkTe

Running Flink jobs directly from Eclipse

2016-04-06 Thread Serhiy Boychenko
Cheerz, I have been working last few month on the comparison of different data processing engines and recently came across Apache Flink. After reading different academic papers on comparison of Flink with other data processing I would definitely give it a shot. The only issue I am currently hav