[jira] [Created] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

Shang Yuanchun (Jira)
Robert Metzger created FLINK-2722:
-------------------------------------

             Summary: Use InetAddress.getLocalHost() first when detecting TaskManager IP address
                 Key: FLINK-2722
                 URL: https://issues.apache.org/jira/browse/FLINK-2722
             Project: Flink
          Issue Type: Bug
          Components: Distributed Runtime, TaskManager
    Affects Versions: 0.9, 0.10
            Reporter: Robert Metzger
            Assignee: Robert Metzger


A user reported a connection issue with Netty being unable to connect to a TaskManager to subscribe to an intermediate result.

The problem occurred when the TaskManager and JobManager were running on the same host (something that can easily happen on YARN).
In that case, the TaskManager was reporting a host-local ip address to the JobManager when connecting.

To avoid the issue in the future, the TaskManager first tries to use the hostname returned by InetAddress.getLocalHost(). In a properly set-up environment, this will return a connection which is accessible by all machines in a cluster.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)