You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/16 11:22:00 UTC

[jira] [Created] (FLINK-23811) Handle FINISHED subtasks in CommonTestUtils.waitForAllTaskRunning

Roman Khachatryan created FLINK-23811:
-----------------------------------------

             Summary: Handle FINISHED subtasks in CommonTestUtils.waitForAllTaskRunning
                 Key: FLINK-23811
                 URL: https://issues.apache.org/jira/browse/FLINK-23811
             Project: Flink
          Issue Type: Improvement
          Components: Tests
    Affects Versions: 1.14.0
            Reporter: Roman Khachatryan


 CommonTestUtils.waitForAllTaskRunning returns when all the subtasks are running AND the job is running and not finished. However, with FLIP-147, subtasks may finish and the job will still be running. So the method won't return and instead timeout.

 

The solution could be:
- For new tests that can have finished subtasks treat return if subtask is RUNING || FINISHED
- For old tests (that assume no finished subtasks) throw an exception


Note that a subtask may be in some other state (e.g. CANCELLED) which is fine, as it can change after failing over the job.

 

This change is extracted from FLINK-21090 into a separate ticket because multiple IT cases might be affected.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)