You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by tillrohrmann <gi...@git.apache.org> on 2016/03/03 14:31:23 UTC
[GitHub] flink pull request: [FLINK-3570] [runtime] Use InetAddress.getLoca...
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1758
[FLINK-3570] [runtime] Use InetAddress.getLocalHost() as heuristic to find local address
The ConnectionUtils.findAddressUsingStrategy method tries to find out the local address which is
accessible by other machines of the cluster. It tries to connect to a specified address to do so.
In case that the no connection could be established, it uses an heuristic. Before it randomly
picked a NetworkInterface which is bound to an Inet4Address, not a loop back address and not a
link local address. In most cases it makes more sense to default to the
InetAddress.getLocalHost() address instead. This PR replaces the old heuristic with simply
returning the InetAddress.getLocalHost(). This of course requires that the system on which Flink
is running, is properly configured.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixNICHeuristic
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1758.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1758
----
commit 121fe848d2ef55af36445dae7e8b0a9ffb468daf
Author: Till Rohrmann <tr...@apache.org>
Date: 2016-03-03T13:24:42Z
[FLINK-3570] [runtime] Use InetAddress.getLocalHost() as heuristic to find local address
The ConnectionUtils.findAddressUsingStrategy method tries to find out the local address which is
accessible by other machines of the cluster. It tries to connect to a specified address to do so.
In case that the no connection could be established, it uses an heuristic. Before it randomly
picked a NetworkInterface which is bound to an Inet4Address, not a loop back address and not a
link local address. In most cases it makes more sense to default to the
InetAddress.getLocalHost() address instead. This PR replaces the old heuristic with simply
returning the InetAddress.getLocalHost(). This of course requires that the system on which Flink
is running, is properly configured.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: [FLINK-3570] [runtime] Use InetAddress.getLoca...
Posted by uce <gi...@git.apache.org>.
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1758#issuecomment-192205023
I'm going to merge this today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: [FLINK-3570] [runtime] Use InetAddress.getLoca...
Posted by StephanEwen <gi...@git.apache.org>.
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1758#issuecomment-192201484
+1 - pretty important in my opinion
please merge into 1.0 and 1.1 branches
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: [FLINK-3570] [runtime] Use InetAddress.getLoca...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1758
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---