Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5665#discussion_r181755304
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java
---
@@ -217,12 +231,12 @@ public void getTaskManagerLogAndStdoutFiles() {
@Test
public void getConfiguration() {
try {
- String config =
TestBaseUtils.getFromHTTP("http://localhost:" + port + "/jobmanager/config");
+ String config =
TestBaseUtils.getFromHTTP("http://localhost:" + CLUSTER.getWebUIPort() +
"/jobmanager/config");
Map<String, String> conf =
WebMonitorUtils.fromKeyValueJsonArray(config);
assertEquals(
-
cluster.configuration().getString("taskmanager.numberOfTaskSlots", null),
-
conf.get(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS));
+
CLUSTER_CONFIGURATION.getString(ConfigConstants.LOCAL_START_WEBSERVER, null),
--- End diff --
what was up here? ð
---