flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kostas Kloudas (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-3896) Allow a StreamTask to be Externally Cancelled.
Date Tue, 14 Jun 2016 17:50:27 GMT

     [ https://issues.apache.org/jira/browse/FLINK-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Kostas Kloudas closed FLINK-3896.
    Resolution: Fixed

> 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

View raw message