David Anderson created FLINK-4828:

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

Reply via email to