[jira] [Created] (FLINK-2313) Change Streaming Driver Execution Model

[Shang Yuanchun (Jira)]

Stephan Ewen created FLINK-2313:
-----------------------------------

             Summary: Change Streaming Driver Execution Model
                 Key: FLINK-2313
                 URL: https://issues.apache.org/jira/browse/FLINK-2313
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Stephan Ewen


I would propose the following change to the Streaming Execution Environment:

When calling {{env.execute()}}, it does not block, but return an {{ExecutionContext}} object. This execution context has various methods, that allow you to control the execution:

  - waitFor() -> Blocks until the job terminates, or the connection to the JobManager is lost.
  - stop() -> initiates a clean stop
  - cancel() -> cancels the program
  - setParallelism() -> Later: adjusts the parallelism of the program


If this is voted as desirable, I would make a design how to do this...



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)