[jira] [Commented] (FLINK-4828) execute stream job asynchronously
[ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574839#comment-15574839 ] Stephan Ewen commented on FLINK-4828: - I think this is a special case of that issue: https://issues.apache.org/jira/browse/FLINK-2313 > execute stream job asynchronously > - > > Key: FLINK-4828 > URL: https://issues.apache.org/jira/browse/FLINK-4828 > Project: Flink > Issue Type: New Feature > Components: DataStream API >Reporter: David Anderson > > It is currently awkward to work with datastreams in a notebook (e.g. Zeppelin > or Jupyter) because env.execute() never returns, and there is no way to > control the job that has been started. It would be much better to have a > variant like env.executeAsync() that executes the job in another thread, and > returns right away. This method should return an object that can be used to > cancel or stop the job. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4828) execute stream job asynchronously
[ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574815#comment-15574815 ] David Anderson commented on FLINK-4828: --- It's not clear to me what this would do to the output from the taskmanager that's going to stdout. > execute stream job asynchronously > - > > Key: FLINK-4828 > URL: https://issues.apache.org/jira/browse/FLINK-4828 > Project: Flink > Issue Type: New Feature > Components: DataStream API >Reporter: David Anderson > > It is currently awkward to work with datastreams in a notebook (e.g. Zeppelin > or Jupyter) because env.execute() never returns, and there is no way to > control the job that has been started. It would be much better to have a > variant like env.executeAsync() that executes the job in another thread, and > returns right away. This method should return an object that can be used to > cancel or stop the job. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
