[
https://issues.apache.org/jira/browse/FLINK-1518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15044036#comment-15044036
]
Ufuk Celebi commented on FLINK-1518:
------------------------------------
Yes, will do.
Sorry for the confusing formulation. I didn't mean to say that this is related
to the web interface. Just noticed it there.
> Laggy task cancelling on task managers
> --------------------------------------
>
> Key: FLINK-1518
> URL: https://issues.apache.org/jira/browse/FLINK-1518
> Project: Flink
> Issue Type: Improvement
> Components: Distributed Runtime
> Affects Versions: 0.10.0
> Reporter: Ufuk Celebi
>
> When cancelling a task on a cluster setup via the web interface I've noticed
> that task cancellation is laggy. The tasks switch to the CANCELING state, but
> the cancelling of the tasks takes some time.
> There are also corresponding log messages:
> {code}
> 14:29:29,281 WARN org.apache.flink.runtime.execution.RuntimeEnvironment
> - Task CHAIN DataSource (at getTextDataSet(WordCount.java:141)
> (org.apache.flink.api.java.io.TextInputF
> /02/11/2015 14:53:22 CHAIN DataSource (at
> getTextDataSet(WordCount.java:141)
> (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at
> main(WordCount.java:67)) -> │ormat)) -> FlatMap (FlatMap at
> main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67) (7/24)
> did not react to cancelling signal. Sending repeated interrupt.
> {code}
> Tasks are cancelled at the task managers by repeatedly sending an interrupt
> signal to the task threads.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
