Re: Executing a flink program

2016-10-10 Thread Maximilian Michels
Whoops, I meant Flink and not Beam (I had just visited the Beam mailing list). -Max On Mon, Oct 10, 2016 at 12:08 PM, Maximilian Michels wrote: > Normally, you should be able to directly execute your Beam program > from within your IDE. It automatically starts a local cluster with the > resourc

Re: Executing a flink program

2016-10-10 Thread Maximilian Michels
Normally, you should be able to directly execute your Beam program from within your IDE. It automatically starts a local cluster with the resources needed for the job. Which Beam version are you using? Could you post some of the code your executing? -Max On Sat, Oct 8, 2016 at 7:51 PM, Dayong

Re: Executing a flink program

2016-10-08 Thread Dayong
You are able to run directly in IDE. Make sure you have right jar and port open. You can try examples shipped with flink source. Thanks, Dayong > On Oct 8, 2016, at 1:35 PM, Abdul Salam Shaikh > wrote: > > Is it necessary to compile a flink program into a jar and deploy it using > command li

Executing a flink program

2016-10-08 Thread Abdul Salam Shaikh
Is it necessary to compile a flink program into a jar and deploy it using command line or we can directly execute the main class in IDE's like Netbeans. While trying to execute from the IDE I am always getting the following exception: Caused by: org.apache.flink.runtime.client.JobExecutionExcepti