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)