[FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address (127.0.0.1) with local environments.
Using loopback rather than the "local address" allows tests to run in situations where the local machine's hostname may not be resolvable in DNS (because DNS is unreacable or the hostname is not found) or the hostname does resolve, but not to an IP address that is reachable. This closes #3223 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31046192 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31046192 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/31046192 Branch: refs/heads/master Commit: 3104619250fa0e0e87b4bb3e05b1cce9d39e6983 Parents: 4ce2557 Author: Rick Cox <[email protected]> Authored: Thu Jan 26 14:55:23 2017 -0800 Committer: Stephan Ewen <[email protected]> Committed: Mon Feb 20 01:01:23 2017 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/contrib/streaming/DataStreamUtils.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/31046192/flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/DataStreamUtils.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/DataStreamUtils.java b/flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/DataStreamUtils.java index d4ef9ee..2987597 100644 --- a/flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/DataStreamUtils.java +++ b/flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/DataStreamUtils.java @@ -21,6 +21,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.runtime.net.ConnectionUtils; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.datastream.DataStreamSink; +import org.apache.flink.streaming.api.environment.LocalStreamEnvironment; import org.apache.flink.streaming.api.environment.RemoteStreamEnvironment; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; @@ -57,6 +58,8 @@ public final class DataStreamUtils { throw new IOException("Could not determine an suitable network address to " + "receive back data from the streaming program.", e); } + } else if (env instanceof LocalStreamEnvironment) { + clientAddress = InetAddress.getLoopbackAddress(); } else { try { clientAddress = InetAddress.getLocalHost();
