This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 5244bb6b8a738aeb630255024e452061417f9440 Author: Tzu-Li (Gordon) Tai <[email protected]> AuthorDate: Tue May 12 23:08:25 2020 +0800 [FLINK-17516] [e2e] Expose master REST port in StatefulFunctionsAppContainers --- .../flink/statefun/e2e/common/StatefulFunctionsAppContainers.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/StatefulFunctionsAppContainers.java b/statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/StatefulFunctionsAppContainers.java index 9a3f2a3..5880ae3 100644 --- a/statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/StatefulFunctionsAppContainers.java +++ b/statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/StatefulFunctionsAppContainers.java @@ -147,6 +147,11 @@ public final class StatefulFunctionsAppContainers extends ExternalResource { workers.forEach(GenericContainer::stop); } + /** @return the exposed port on master for calling REST APIs. */ + public int getMasterRestPort() { + return master.getMappedPort(8081); + } + public static final class Builder { private static final String MASTER_HOST = "statefun-app-master"; private static final String WORKER_HOST_PREFIX = "statefun-app-worker"; @@ -289,7 +294,8 @@ public final class StatefulFunctionsAppContainers extends ExternalResource { .withNetworkAliases(MASTER_HOST) .withEnv("ROLE", "master") .withEnv("MASTER_HOST", MASTER_HOST) - .withCommand("-p " + numWorkers); + .withCommand("-p " + numWorkers) + .withExposedPorts(8081); for (GenericContainer<?> dependent : dependents) { master.dependsOn(dependent);
