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 3ebf94051ea234b4bec41b36e802f6cbcf18521d Author: Dawid Wysakowicz <[email protected]> AuthorDate: Tue Apr 13 09:35:01 2021 +0200 [FLINK-22249][tests] Add `FAILLING` to an assertion in JobMasterStopWithSavepointITCase --- .../flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 ad92ee5..47891aa 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 @@ -154,7 +154,8 @@ public class JobMasterStopWithSavepointITCase extends AbstractTestBase { // verifying that we actually received a synchronous checkpoint assertTrue(syncSavepointId.get() > 0); - assertThat(getJobStatus(), equalTo(JobStatus.FAILED)); + assertThat( + getJobStatus(), either(equalTo(JobStatus.FAILED)).or(equalTo(JobStatus.FAILING))); } @Test(timeout = 5000)
