[
https://issues.apache.org/jira/browse/FLINK-5669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5669.
---------------------------------
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Fixed in
- 1.2.1 via 6955030d5faaf3ffb6156171eed38f10c254295d
- 1.3.0 via 3104619250fa0e0e87b4bb3e05b1cce9d39e6983
> flink-streaming-contrib DataStreamUtils.collect in local environment mode
> fails when offline
> --------------------------------------------------------------------------------------------
>
> Key: FLINK-5669
> URL: https://issues.apache.org/jira/browse/FLINK-5669
> Project: Flink
> Issue Type: Bug
> Components: flink-contrib
> Reporter: Rick Cox
> Priority: Minor
> Fix For: 1.3.0, 1.2.1
>
>
> {{DataStreamUtils.collect()}} needs to obtain the local machine's IP so that
> the job can send the results back. In the case of local
> {{StreamEnvironments}}, it uses {{InetAddress.getLocalHost()}}, which
> attempts to resolve the local hostname using DNS.
> If DNS is not available (for example, when offline) or if DNS is available
> but cannot resolve the hostname (for example, if the hostname is an intranet
> name but the machine is not currently on that network), an
> {{UnknownHostException}} will be thrown (and wrapped in an {{IOException}}).
> If the resolved IP is not reachable for some reason, streaming results will
> fail.
> Since this case is for local execution only, it seems that using
> {{InetAddress.getLoopbackAddress()}} would work just as well, and avoid the
> assumptions made by {{getLocalHost()}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
