flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [tests] Activate ChaosMonkeyITCase
Date Mon, 30 Nov 2015 15:35:18 GMT
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 <trohrmann@apache.org>
Authored: Wed Nov 25 13:05:22 2015 +0100
Committer: Till Rohrmann <trohrmann@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");


Mime
View raw message