You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/04/13 18:23:33 UTC
[3/5] flink git commit: [FLINK-1879] [client] Simplify JobClient.
Hide actorRefs behind method calls where possible.
http://git-wip-us.apache.org/repos/asf/flink/blob/ad637077/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
index 7449215..0b6c981 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
@@ -101,7 +101,7 @@ with WordSpecLike with Matchers with BeforeAndAfterAll {
try {
within(TestingUtils.TESTING_DURATION) {
- jm ! SubmitJob(jobGraph)
+ jm ! SubmitJob(jobGraph, false)
expectMsg(Success(jobGraph.getJobID))
jm ! WaitForAllVerticesToBeRunningOrFinished(jobID)
@@ -148,7 +148,7 @@ with WordSpecLike with Matchers with BeforeAndAfterAll {
try {
within(TestingUtils.TESTING_DURATION) {
- jm ! SubmitJob(jobGraph)
+ jm ! SubmitJob(jobGraph, false)
expectMsg(Success(jobGraph.getJobID))
jm ! WaitForAllVerticesToBeRunningOrFinished(jobID)
@@ -191,7 +191,7 @@ with WordSpecLike with Matchers with BeforeAndAfterAll {
try{
within(TestingUtils.TESTING_DURATION){
- jm ! SubmitJob(jobGraph)
+ jm ! SubmitJob(jobGraph, false)
expectMsg(Success(jobGraph.getJobID))
tm ! PoisonPill
@@ -213,7 +213,7 @@ with WordSpecLike with Matchers with BeforeAndAfterAll {
expectMsg(RegisteredAtJobManager)
- jm ! SubmitJob(jobGraph2)
+ jm ! SubmitJob(jobGraph2, false)
expectMsgType[Success]