flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1518) Laggy task cancelling on task managers
Date Wed, 11 Feb 2015 13:58:11 GMT
Ufuk Celebi created FLINK-1518:

             Summary: 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: master
            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

There are also corresponding log messages:

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.

Tasks are cancelled at the task managers by repeatedly sending an interrupt signal to the
task threads.

This message was sent by Atlassian JIRA

View raw message