Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-135852748 I just pushed an update addressing your comments. I additionally rework all TaskManager and JobManager test. Open issues: 1. how to deal with (potentially blocking) `userfunction.cancel()` 2. discussion about error message vs. exception (-> `StoppingFailiure`, `CancelFailure`, and `TaskOperationResult`) From my point of view, the error-message vs. exception thing could be cleaned up in a different JIRA, in case it should be changed to use the exception approach. For `cancel` it might be sufficient to simply document that the call must be non blocking.
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---