[FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2bbc92cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2bbc92cf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2bbc92cf Branch: refs/heads/release-1.2 Commit: 2bbc92cf637b2caf612c43b0f35ba2282b5bc981 Parents: 7f20bd0 Author: zentol <ches...@apache.org> Authored: Mon Dec 12 18:15:14 2016 +0100 Committer: zentol <ches...@apache.org> Committed: Thu Jan 19 21:42:01 2017 +0100 ---------------------------------------------------------------------- .../flink/runtime/minicluster/LocalFlinkMiniCluster.scala | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2bbc92cf/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala index 09deadc..7f3e7e6 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala @@ -130,6 +130,10 @@ class LocalFlinkMiniCluster( ioExecutor, createLeaderElectionService()) + if (config.getBoolean(ConfigConstants.LOCAL_START_WEBSERVER, false)) { + metricsRegistry.get.startQueryService(system, null) + } + val archive = system.actorOf( getArchiveProps( memoryArchivistClass, @@ -229,7 +233,9 @@ class LocalFlinkMiniCluster( leaderRetrievalService, metricsRegistry) - metricsRegistry.startQueryService(system, resourceID) + if (config.getBoolean(ConfigConstants.LOCAL_START_WEBSERVER, false)) { + metricsRegistry.startQueryService(system, resourceID) + } system.actorOf(props, taskManagerActorName) }
