From 0956b94a910df071a61aae90cac7fef2b795ed0c Mon Sep 17 00:00:00 2001 From: "shuai.xus" Date: Wed, 20 Dec 2017 17:37:10 +0800 Subject: [PATCH] [FLINK-8289] [runtime] set the rest.address to the host of the rest server machine --- .../org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java index 156efdc5beccf..961afd5b02538 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java @@ -23,6 +23,7 @@ import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.GlobalConfiguration; import org.apache.flink.configuration.JobManagerOptions; +import org.apache.flink.configuration.RestOptions; import org.apache.flink.core.fs.FileSystem; import org.apache.flink.runtime.akka.AkkaUtils; import org.apache.flink.runtime.blob.BlobServer; @@ -155,6 +156,7 @@ protected void runCluster(Configuration configuration) throws Exception { // write host information into configuration configuration.setString(JobManagerOptions.ADDRESS, commonRpcService.getAddress()); configuration.setInteger(JobManagerOptions.PORT, commonRpcService.getPort()); + configuration.setString(RestOptions.REST_ADDRESS, commonRpcService.getAddress()); startClusterComponents( configuration,