Repository: flink Updated Branches: refs/heads/master 77348858f -> b9a6a5cb5
[FLINK-3212] [tests] Add RetryOnFailure rule to JobManagerCheckpointRecoveryITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b9a6a5cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b9a6a5cb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b9a6a5cb Branch: refs/heads/master Commit: b9a6a5cb5401fbda3a0eb4b910eb4f3f951af9cb Parents: 7734885 Author: Ufuk Celebi <u...@apache.org> Authored: Mon Jan 11 16:46:33 2016 +0100 Committer: Ufuk Celebi <u...@apache.org> Committed: Mon Jan 11 16:46:33 2016 +0100 ---------------------------------------------------------------------- .../test/recovery/JobManagerCheckpointRecoveryITCase.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b9a6a5cb/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerCheckpointRecoveryITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerCheckpointRecoveryITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerCheckpointRecoveryITCase.java index c13d42d..cc4998d 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerCheckpointRecoveryITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerCheckpointRecoveryITCase.java @@ -45,9 +45,12 @@ import org.apache.flink.streaming.api.checkpoint.Checkpointed; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.sink.SinkFunction; import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction; +import org.apache.flink.testutils.junit.RetryOnFailure; +import org.apache.flink.testutils.junit.RetryRule; import org.apache.flink.util.TestLogger; import org.junit.AfterClass; import org.junit.Before; +import org.junit.Rule; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -73,6 +76,9 @@ import static org.junit.Assert.assertTrue; public class JobManagerCheckpointRecoveryITCase extends TestLogger { + @Rule + public RetryRule retryRule = new RetryRule(); + private final static ZooKeeperTestEnvironment ZooKeeper = new ZooKeeperTestEnvironment(1); private final static FiniteDuration TestTimeOut = new FiniteDuration(5, TimeUnit.MINUTES); @@ -129,6 +135,7 @@ public class JobManagerCheckpointRecoveryITCase extends TestLogger { * this test actually tests something. */ @Test + @RetryOnFailure(times=1) public void testCheckpointedStreamingSumProgram() throws Exception { // Config final int checkpointingInterval = 200; @@ -279,6 +286,7 @@ public class JobManagerCheckpointRecoveryITCase extends TestLogger { * @see <a href="https://issues.apache.org/jira/browse/FLINK-3185";>FLINK-3185</a> */ @Test + @RetryOnFailure(times=1) public void testCheckpointRecoveryFailure() throws Exception { final Deadline testDeadline = TestTimeOut.fromNow(); final String zooKeeperQuorum = ZooKeeper.getConnectString();
