flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [hotfix] Fx TestingyYarnJobManager constructor
Date Fri, 01 Jul 2016 14:25:38 GMT
Repository: flink
Updated Branches:
  refs/heads/master 0483ba583 -> f36aa6ff3


[hotfix] Fx TestingyYarnJobManager constructor


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

Branch: refs/heads/master
Commit: f36aa6ff32164d46da5fa1795c8e3fa3d9c18eba
Parents: 0483ba5
Author: zentol <chesnay@apache.org>
Authored: Fri Jul 1 16:23:34 2016 +0200
Committer: zentol <chesnay@apache.org>
Committed: Fri Jul 1 16:24:24 2016 +0200

----------------------------------------------------------------------
 .../scala/org/apache/flink/yarn/TestingYarnJobManager.scala   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f36aa6ff/flink-yarn-tests/src/test/scala/org/apache/flink/yarn/TestingYarnJobManager.scala
----------------------------------------------------------------------
diff --git a/flink-yarn-tests/src/test/scala/org/apache/flink/yarn/TestingYarnJobManager.scala
b/flink-yarn-tests/src/test/scala/org/apache/flink/yarn/TestingYarnJobManager.scala
index 2f93785..6a6faf5 100644
--- a/flink-yarn-tests/src/test/scala/org/apache/flink/yarn/TestingYarnJobManager.scala
+++ b/flink-yarn-tests/src/test/scala/org/apache/flink/yarn/TestingYarnJobManager.scala
@@ -23,6 +23,7 @@ import java.util.concurrent.ExecutorService
 import akka.actor.ActorRef
 import org.apache.flink.configuration.Configuration
 import org.apache.flink.runtime.checkpoint.{SavepointStore, CheckpointRecoveryFactory}
+import org.apache.flink.metrics.MetricRegistry
 import org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager
 import org.apache.flink.runtime.executiongraph.restart.RestartStrategyFactory
 import org.apache.flink.runtime.instance.InstanceManager
@@ -63,7 +64,8 @@ class TestingYarnJobManager(
     submittedJobGraphs : SubmittedJobGraphStore,
     checkpointRecoveryFactory : CheckpointRecoveryFactory,
     savepointStore: SavepointStore,
-    jobRecoveryTimeout: FiniteDuration)
+    jobRecoveryTimeout: FiniteDuration,
+    metricRegistry : Option[MetricRegistry])
   extends YarnJobManager(
     flinkConfiguration,
     executorService,
@@ -77,5 +79,6 @@ class TestingYarnJobManager(
     submittedJobGraphs,
     checkpointRecoveryFactory,
     savepointStore,
-    jobRecoveryTimeout)
+    jobRecoveryTimeout,
+    metricRegistry)
   with TestingJobManagerLike {}


Mime
View raw message