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
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