[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478573#comment-17478573 ]
Yun Gao commented on FLINK-24163: --------------------------------- Very thanks [~roman] for the explanation! If the behavior is expected, I think I could first try to modify the test to reduce the running time or extend the waiting time. And for the long run, does it affect normal jobs in realistic and do we have plan to reduce this part~? > PartiallyFinishedSourcesITCase fails due to timeout > --------------------------------------------------- > > Key: FLINK-24163 > URL: https://issues.apache.org/jira/browse/FLINK-24163 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Affects Versions: 1.14.0, 1.15.0 > Reporter: Xintong Song > Assignee: Yun Gao > Priority: Blocker > Labels: pull-request-available, test-stability > Fix For: 1.14.0, 1.15.0 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23529&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bdf4887&t=7b25afdf-cc6c-566f-5459-359dc2585798&l=10996 > {code} > Sep 04 04:35:28 [ERROR] Tests run: 6, Failures: 0, Errors: 1, Skipped: 0, > Time elapsed: 155.236 s <<< FAILURE! - in > org.apache.flink.runtime.operators.lifecycle.PartiallyFinishedSourcesITCase > Sep 04 04:35:28 [ERROR] test[complex graph ALL_SUBTASKS, failover: false] > Time elapsed: 65.999 s <<< ERROR! > Sep 04 04:35:28 java.util.concurrent.TimeoutException: Condition was not met > in given timeout. > Sep 04 04:35:28 at > org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:164) > Sep 04 04:35:28 at > org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:142) > Sep 04 04:35:28 at > org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:134) > Sep 04 04:35:28 at > org.apache.flink.runtime.testutils.CommonTestUtils.waitForSubtasksToFinish(CommonTestUtils.java:297) > Sep 04 04:35:28 at > org.apache.flink.runtime.operators.lifecycle.TestJobExecutor.waitForSubtasksToFinish(TestJobExecutor.java:219) > Sep 04 04:35:28 at > org.apache.flink.runtime.operators.lifecycle.PartiallyFinishedSourcesITCase.test(PartiallyFinishedSourcesITCase.java:82) > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)