flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From StephanEwen <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-2967] Enhance TaskManager network detec...
Date Tue, 17 Nov 2015 12:09:47 GMT
Github user StephanEwen commented on a diff in the pull request:

    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java
    @@ -180,7 +180,41 @@ public static InetAddress findConnectingAddress(InetSocketAddress
    +	/**
    +	 * This utility method tries to connect to the JobManager using the InetAddress returned
    +	 * InetAddress.getLocalHost(). The purpose of the utility is to have a final try connecting
    +	 * the target address using the LocalHost before using the address returned.
    +	 * We do a second try because the JM might have been unavailable during the first check.
    +	 *
    +	 * @param preliminaryResult The address detected by the heuristic
    +	 * @return either the preliminaryResult or the address returned by InetAddress.getLocalHost()
    +	 * 			we are able to connect to targetAddress from there)
    +	 */
    +	private static InetAddress tryLocalHostBeforeReturning(InetAddress preliminaryResult,
SocketAddress targetAddress, boolean logging) throws IOException {
    +		InetAddress localhostName = InetAddress.getLocalHost();
    +		if(tryToConnect(localhostName, targetAddress, AddressDetectionState.LOCAL_HOST.getTimeout(),
logging)) {
    --- End diff --
    Also: code style, space

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.

View raw message