You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/01/20 05:40:07 UTC
[11/18] flink git commit: [FLINK-5321] [metrics]
LocalFlinkMiniCluster starts JM MetricQS
[FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS
This closes #2991.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b36b43b9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b36b43b9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b36b43b9
Branch: refs/heads/master
Commit: b36b43b9ad3f4b04a2a701b9139bb3eaf17b9ff8
Parents: 6c03491
Author: zentol <ch...@apache.org>
Authored: Mon Dec 12 18:15:14 2016 +0100
Committer: zentol <ch...@apache.org>
Committed: Thu Jan 19 23:57:22 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/b36b43b9/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 671c6f5..4ec655e 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
@@ -132,6 +132,10 @@ class LocalFlinkMiniCluster(
ioExecutor,
createLeaderElectionService())
+ if (config.getBoolean(ConfigConstants.LOCAL_START_WEBSERVER, false)) {
+ metricsRegistry.get.startQueryService(system, null)
+ }
+
val archive = system.actorOf(
getArchiveProps(
memoryArchivistClass,
@@ -232,7 +236,9 @@ class LocalFlinkMiniCluster(
createLeaderRetrievalService(),
metricRegistry)
- metricRegistry.startQueryService(system, resourceID)
+ if (config.getBoolean(ConfigConstants.LOCAL_START_WEBSERVER, false)) {
+ metricRegistry.startQueryService(system, resourceID)
+ }
system.actorOf(props, taskManagerActorName)
}