提交 f36aa6ff 编写于 作者: Z zentol

[hotfix] Fx TestingyYarnJobManager constructor

上级 0483ba58
......@@ -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 {}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册