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 2018/04/19 08:01:15 UTC
[2/9] flink git commit: [FLINK-8703][tests] Expose WebUI port
[FLINK-8703][tests] Expose WebUI port
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f39ffd3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f39ffd3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0f39ffd3
Branch: refs/heads/release-1.5
Commit: 0f39ffd308c88d791b2dfc1f3fd57e415b3ecfeb
Parents: c53d59f
Author: zentol <ch...@apache.org>
Authored: Wed Mar 7 11:14:20 2018 +0100
Committer: zentol <ch...@apache.org>
Committed: Thu Apr 19 10:01:00 2018 +0200
----------------------------------------------------------------------
.../org/apache/flink/test/util/MiniClusterResource.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0f39ffd3/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
----------------------------------------------------------------------
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
index 324c9ee..160c1d1 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
@@ -75,6 +75,8 @@ public class MiniClusterResource extends ExternalResource {
private TestEnvironment executionEnvironment;
+ private int webUIPort = -1;
+
public MiniClusterResource(final MiniClusterResourceConfiguration miniClusterResourceConfiguration) {
this(miniClusterResourceConfiguration, false);
}
@@ -129,6 +131,10 @@ public class MiniClusterResource extends ExternalResource {
return executionEnvironment;
}
+ public int getWebUIPort() {
+ return webUIPort;
+ }
+
@Override
public void before() throws Exception {
@@ -205,6 +211,10 @@ public class MiniClusterResource extends ExternalResource {
Configuration restClientConfig = new Configuration();
restClientConfig.setInteger(JobManagerOptions.PORT, flinkMiniCluster.getLeaderRPCPort());
this.restClusterClientConfig = new UnmodifiableConfiguration(restClientConfig);
+
+ if (flinkMiniCluster.webMonitor().isDefined()) {
+ webUIPort = flinkMiniCluster.webMonitor().get().getServerPort();
+ }
}
private void startMiniCluster() throws Exception {
@@ -244,6 +254,8 @@ public class MiniClusterResource extends ExternalResource {
restClientConfig.setString(JobManagerOptions.ADDRESS, miniCluster.getRestAddress().getHost());
restClientConfig.setInteger(RestOptions.PORT, miniCluster.getRestAddress().getPort());
this.restClusterClientConfig = new UnmodifiableConfiguration(restClientConfig);
+
+ webUIPort = miniCluster.getRestAddress().getPort();
}
/**