Repository: flink Updated Branches: refs/heads/master 20ebad048 -> 2b358cde0
[tests] Activate ChaosMonkeyITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b358cde Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b358cde Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2b358cde Branch: refs/heads/master Commit: 2b358cde0d232a3bfbc59fa9a6845b0c754f1704 Parents: 20ebad0 Author: Till Rohrmann <trohrm...@apache.org> Authored: Wed Nov 25 13:05:22 2015 +0100 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Mon Nov 30 16:34:26 2015 +0100 ---------------------------------------------------------------------- .../org/apache/flink/test/recovery/ChaosMonkeyITCase.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2b358cde/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java index f536418..3ec8380 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java @@ -69,7 +69,6 @@ import static com.google.common.base.Preconditions.checkArgument; import static org.junit.Assert.assertEquals; import static org.junit.Assert.fail; -@Ignore public class ChaosMonkeyITCase { private static final Logger LOG = LoggerFactory.getLogger(ChaosMonkeyITCase.class); @@ -135,19 +134,19 @@ public class ChaosMonkeyITCase { // will be killed. On recovery (which takes some time to bring up the new process etc.), // this test will wait for task managers to reconnect before starting the next count down. // Therefore the delay between retries is not important in this setup. - final FiniteDuration killEvery = new FiniteDuration(30, TimeUnit.SECONDS); + final FiniteDuration killEvery = new FiniteDuration(5, TimeUnit.SECONDS); // Trigger a checkpoint every - final int checkpointingIntervalMs = 2000; + final int checkpointingIntervalMs = 1000; // Total number of kills - final int totalNumberOfKills = 5; + final int totalNumberOfKills = 10; // ----------------------------------------------------------------------------------------- // Setup Configuration config = ZooKeeperTestUtils.createZooKeeperRecoveryModeConfig( - ZooKeeper.getConnectString(), FileStateBackendBasePath.getPath()); + ZooKeeper.getConnectString(), FileStateBackendBasePath.toURI().toString()); // Akka and restart timeouts config.setString(ConfigConstants.AKKA_WATCH_HEARTBEAT_INTERVAL, "1000 ms");
