GitHub user PhilippGrulich opened a pull request:
ZEPPELIN-1632 Add the possibility to cancel flink jobs in local mode
- What is this PR for?
Especially for long running flink streaming jobs it should be possible to cancel a job by clicking the cancel button in the zeppelin ui. This pull request contains an implementation to cancel jobs when the flink interpreter is running in local mode.
- What type of PR is it?
- [ ] - Implement cancel method
- What is the Jira issue?
- How should this be tested?
Execute a long running flink streaming job.
The "senv.execute()" method is blocking, therefore the paragraph remains in the state running. Then click cancel and the job will be canceled.
- Does the licenses files need update? No
- Is there breaking changes for older versions? No
- Does this needs documentation? No
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/SWC-SENSE/zeppelin flink_cancel_job
Alternatively you can review and apply these changes as the patch at:
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1607
Author: Philipp <email@example.com>
add the possibility to cancel flink jobs in local mode