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 <ches...@apache.org> Authored: Fri Jul 1 16:23:34 2016 +0200 Committer: zentol <ches...@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 {}
