flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [11/18] flink git commit: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS
Date Fri, 20 Jan 2017 05:40:07 GMT
[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 <chesnay@apache.org>
Authored: Mon Dec 12 18:15:14 2016 +0100
Committer: zentol <chesnay@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)
   }


Mime
View raw message