You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/02/08 15:05:35 UTC

[02/12] flink git commit: [hotfix] [runtime] Create TestingJobManager in TestingUtils

[hotfix] [runtime] Create TestingJobManager in TestingUtils


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

Branch: refs/heads/master
Commit: 414704082764f71924fb3813d8c4c75189098556
Parents: 20f8911
Author: Ufuk Celebi <uc...@apache.org>
Authored: Mon Feb 1 17:28:34 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Mon Feb 8 15:04:43 2016 +0100

----------------------------------------------------------------------
 .../scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/41470408/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
index 02b0cf8..98faa34 100644
--- a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
+++ b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
@@ -272,7 +272,7 @@ object TestingUtils {
         actorSystem,
         Some(JobManager.JOB_MANAGER_NAME),
         Some(JobManager.ARCHIVE_NAME),
-        classOf[JobManager],
+        classOf[TestingJobManager],
         classOf[MemoryArchivist])
 
     new AkkaActorGateway(actor, null)