[hotfix] Speed up JobManagerFailsITCase by decreasing timeout
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/865ce91e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/865ce91e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/865ce91e Branch: refs/heads/master Commit: 865ce91e2820fec0e6b3207aefdc9f885ca68ec4 Parents: 3e36fd6 Author: Till Rohrmann <trohrm...@apache.org> Authored: Wed Oct 25 13:24:41 2017 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Tue Nov 7 15:07:41 2017 +0100 ---------------------------------------------------------------------- .../scala/runtime/jobmanager/JobManagerFailsITCase.scala | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/865ce91e/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala index e5f26c5..44f14a0 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala @@ -20,15 +20,15 @@ package org.apache.flink.api.scala.runtime.jobmanager import akka.actor.ActorSystem import akka.testkit.{ImplicitSender, TestKit} -import org.apache.flink.configuration.{ConfigConstants, Configuration} +import org.apache.flink.configuration.{ConfigConstants, Configuration, JobManagerOptions} import org.apache.flink.runtime.akka.{AkkaUtils, ListeningBehaviour} import org.apache.flink.runtime.jobgraph.{JobGraph, JobVertex} -import org.apache.flink.runtime.testtasks.{BlockingNoOpInvokable, NoOpInvokable} import org.apache.flink.runtime.messages.Acknowledge import org.apache.flink.runtime.messages.JobManagerMessages._ import org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenAtLeastNumTaskManagerAreRegistered import org.apache.flink.runtime.testingUtils.TestingMessages.DisableDisconnect import org.apache.flink.runtime.testingUtils.{ScalaTestingUtils, TestingCluster, TestingUtils} +import org.apache.flink.runtime.testtasks.{BlockingNoOpInvokable, NoOpInvokable} import org.junit.runner.RunWith import org.scalatest.junit.JUnitRunner import org.scalatest.{BeforeAndAfterAll, Matchers, WordSpecLike} @@ -51,7 +51,7 @@ class JobManagerFailsITCase(_system: ActorSystem) "A TaskManager" should { "detect a lost connection to the JobManager and try to reconnect to it" in { - val num_slots = 13 + val num_slots = 4 val cluster = startDeathwatchCluster(num_slots, 1) try { @@ -83,7 +83,7 @@ class JobManagerFailsITCase(_system: ActorSystem) } "go into a clean state in case of a JobManager failure" in { - val num_slots = 36 + val num_slots = 4 val sender = new JobVertex("BlockingSender") sender.setParallelism(num_slots) @@ -135,6 +135,9 @@ class JobManagerFailsITCase(_system: ActorSystem) val config = new Configuration() config.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, numSlots) config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, numTaskmanagers) + config.setInteger(JobManagerOptions.PORT, 0) + config.setString(ConfigConstants.TASK_MANAGER_INITIAL_REGISTRATION_PAUSE, "50 ms") + config.setString(ConfigConstants.TASK_MANAGER_MAX_REGISTARTION_PAUSE, "100 ms") val cluster = new TestingCluster(config, singleActorSystem = false)