[hotfix] Speed up JobManagerFailsITCase by decreasing timeout

tonycox · Nov 7, 2017 · 865ce91 · 865ce91
1 parent 3e36fd6
commit 865ce91
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/.../src/test/scala/org/apache/flink/api/scala/runtime/jobmanager/JobManagerFailsITCase.scala b/.../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)