flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [tests] Fix missing task parallelism in JobManagerITCase bipartite job support test
Date Fri, 23 Jan 2015 11:07:02 GMT
Repository: flink
Updated Branches:
  refs/heads/master a5702b69e -> fd67328f4


[tests] Fix missing task parallelism in JobManagerITCase bipartite job support test


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd67328f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd67328f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fd67328f

Branch: refs/heads/master
Commit: fd67328f45e670568b501ca3ff7a23d936cbe3a9
Parents: a5702b6
Author: Ufuk Celebi <uce@apache.org>
Authored: Fri Jan 23 12:06:22 2015 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Fri Jan 23 12:06:22 2015 +0100

----------------------------------------------------------------------
 .../flink/runtime/jobmanager/JobManagerITCase.scala | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/fd67328f/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
b/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
index 020231e..c324dc5 100644
--- a/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
+++ b/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
@@ -18,19 +18,19 @@
 
 package org.apache.flink.runtime.jobmanager
 
+import Tasks._
 import akka.actor.ActorSystem
 import akka.testkit.{ImplicitSender, TestKit}
 import org.apache.flink.runtime.akka.AkkaUtils
-import org.apache.flink.runtime.jobgraph.{DistributionPattern, JobGraph,
-AbstractJobVertex}
-import Tasks._
+import org.apache.flink.runtime.jobgraph.{AbstractJobVertex, DistributionPattern, JobGraph}
 import org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException
-import org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenJobRemoved
-import org.apache.flink.runtime.testingUtils.{TestingUtils}
 import org.apache.flink.runtime.messages.JobManagerMessages._
+import org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenJobRemoved
+import org.apache.flink.runtime.testingUtils.TestingUtils
 import org.junit.runner.RunWith
 import org.scalatest.junit.JUnitRunner
-import org.scalatest.{Matchers, WordSpecLike, BeforeAndAfterAll}
+import org.scalatest.{BeforeAndAfterAll, Matchers, WordSpecLike}
+
 import scala.concurrent.duration._
 
 @RunWith(classOf[JUnitRunner])
@@ -178,6 +178,9 @@ WordSpecLike with Matchers with BeforeAndAfterAll {
       sender.setInvokableClass(classOf[Sender])
       receiver.setInvokableClass(classOf[AgnosticReceiver])
 
+      sender.setParallelism(num_tasks)
+      receiver.setParallelism(num_tasks)
+
       receiver.connectNewDataSetAsInput(sender, DistributionPattern.POINTWISE)
 
       val jobGraph = new JobGraph("Bipartite Job", sender, receiver)
@@ -190,6 +193,7 @@ WordSpecLike with Matchers with BeforeAndAfterAll {
           jm ! SubmitJob(jobGraph)
 
           expectMsg(SubmissionSuccess(jobGraph.getJobID))
+
           expectMsgType[JobResultSuccess]
         }
         jm ! NotifyWhenJobRemoved(jobGraph.getJobID)


Mime
View raw message