[jira] [Resolved] (FLINK-5669) flink-streaming-contrib DataStreamUtils.collect in local environment mode fails when offline

["Stephan Ewen (JIRA)" <ji...@apache.org>]

     [ 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)