You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/11/07 14:08:00 UTC
[02/30] flink git commit: [hotfix] Speed up JobManagerFailsITCase by
decreasing timeout
[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 <tr...@apache.org>
Authored: Wed Oct 25 13:24:41 2017 +0200
Committer: Till Rohrmann <tr...@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)