[FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM MetricQS

This closes #2991.
apache · Jan 19, 2017 · b36b43b · b36b43b
1 parent 6c03491
commit b36b43b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...k-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala b/...k-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)
   }