[
https://issues.apache.org/jira/browse/FLINK-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296350#comment-15296350
]
Kostas Kloudas commented on FLINK-3896:
---------------------------------------
This issue came up while implementing FLINK-2314 and the PR for the latter also
contains the solution for this one:
https://github.com/apache/flink/pull/2020
> Allow a StreamTask to be Externally Cancelled.
> ----------------------------------------------
>
> Key: FLINK-3896
> URL: https://issues.apache.org/jira/browse/FLINK-3896
> Project: Flink
> Issue Type: Bug
> Reporter: Kostas Kloudas
> Assignee: Kostas Kloudas
>
> When implementing a custom operator, it may be useful to be able to cancel
> the task it runs into due to an external event. As an example imagine an
> Operator that spawns a thread to do some work and forward the element to the
> next one.
> In this case, if an exception is thrown by that thread, then this will not be
> automatically propagated to the main thread, in order to cancel the task. In
> this case, it would be useful to cancel the task by that thread. This issue
> aims at adding exactly
> this functionality to the StreamTask. Currently a Task can do so, but this is
> not accessible to the StreamTask.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
