Re: Extending StreamExecutionEnvironment

2015-07-17 Thread Stephan Ewen
There is already an issue for this: https://issues.apache.org/jira/browse/FLINK-2313 Before addressing this, I would like to merge https://github.com/apache/flink/pull/858 , because the poll request also touches the Client that communicates with the JobManager. On Thu, Jul 16, 2015 at 3:38 PM, Ma

Extending StreamExecutionEnvironment

2015-07-16 Thread Matthias J. Sax
Hi, currently, StreamExecutionEnvironment runs programs in a blocking fashion, ie, it expects a job to finish by itself. However, streaming jobs might run infinitely. With the upcoming STOP signal, I would recommend to extend StreamExecutionEnvironment such that a job can be executed in a detache