This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 25fa42df3dd0c6d2eada49c7c85619931846c678 Author: Dawid Wysakowicz <[email protected]> AuthorDate: Tue Apr 13 09:47:34 2021 +0200 [FLINK-22248][tests] Remove timeouts from JobMasterStopWithSavepointITCase --- .../jobmaster/JobMasterStopWithSavepointITCase.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java b/flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java index 47891aa..6eec106 100644 --- a/flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java @@ -99,13 +99,13 @@ public class JobMasterStopWithSavepointITCase extends AbstractTestBase { private JobGraph jobGraph; - @Test(timeout = 5000) + @Test public void suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished() throws Exception { stopWithSavepointNormalExecutionHelper(false); } - @Test(timeout = 5000) + @Test public void terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished() throws Exception { stopWithSavepointNormalExecutionHelper(true); @@ -130,12 +130,12 @@ public class JobMasterStopWithSavepointITCase extends AbstractTestBase { assertThat(savepoints, hasItem(Paths.get(savepointLocation).getFileName())); } - @Test(timeout = 5000) + @Test public void throwingExceptionOnCallbackWithNoRestartsShouldFailTheSuspend() throws Exception { throwingExceptionOnCallbackWithoutRestartsHelper(false); } - @Test(timeout = 5000) + @Test public void throwingExceptionOnCallbackWithNoRestartsShouldFailTheTerminate() throws Exception { throwingExceptionOnCallbackWithoutRestartsHelper(true); } @@ -158,13 +158,13 @@ public class JobMasterStopWithSavepointITCase extends AbstractTestBase { getJobStatus(), either(equalTo(JobStatus.FAILED)).or(equalTo(JobStatus.FAILING))); } - @Test(timeout = 5000) + @Test public void throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend() throws Exception { throwingExceptionOnCallbackWithRestartsHelper(false); } - @Test(timeout = 5000) + @Test public void throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate() throws Exception { throwingExceptionOnCallbackWithRestartsHelper(true); @@ -210,7 +210,7 @@ public class JobMasterStopWithSavepointITCase extends AbstractTestBase { either(equalTo(JobStatus.CANCELLING)).or(equalTo(JobStatus.CANCELED))); } - @Test(timeout = 5000) + @Test public void testRestartCheckpointCoordinatorIfStopWithSavepointFails() throws Exception { setUpJobGraph(CheckpointCountingTask.class, RestartStrategies.noRestart());
