[ 
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14487092#comment-14487092
 ] 

Stephan Ewen commented on FLINK-1793:
-------------------------------------

Looks correct.

Since thread existing can only be cooperative in Java (the run method has to 
want to exit), please make sure all driver loops in all operators have such 
checks. Otherwise the canceling hangs. 

> Streaming File Source cannot be canceled
> ----------------------------------------
>
>                 Key: FLINK-1793
>                 URL: https://issues.apache.org/jira/browse/FLINK-1793
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>    Affects Versions: 0.9
>            Reporter: Maximilian Michels
>            Assignee: Márton Balassi
>            Priority: Critical
>             Fix For: 0.9
>
>
> The streaming WordCount gets stuck in the "CANCELED" state after it has been 
> canceled using either the web interface or the command line interface.



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

Reply via email to