org.apache.flink.runtime.net

Class NetUtils

java.lang.Object

org.apache.flink.runtime.net.NetUtils

public class NetUtils
extends Object

Utilities to determine the network interface and address that should be used to bind the TaskManager communication to.

Constructor Summary

Constructors

Constructor and Description
NetUtils()

Method Summary

Modifier and Type	Method and Description
static InetAddress	findConnectingAddress(InetSocketAddress targetAddress, long maxWaitMillis, long startLoggingAfter) Finds the local network address from which this machine can connect to the target address.
static int	getAvailablePort() Find a non-occupied port.
static InetAddress	resolveAddress(InetSocketAddress jobManagerAddress) Find out the TaskManager's own IP address, simple version.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NetUtils

public NetUtils()

Method Detail

resolveAddress

public static InetAddress resolveAddress(InetSocketAddress jobManagerAddress)
                                  throws IOException

Find out the TaskManager's own IP address, simple version.

Throws:

IOException

findConnectingAddress

public static InetAddress findConnectingAddress(InetSocketAddress targetAddress,
                                                long maxWaitMillis,
                                                long startLoggingAfter)
                                         throws IOException

Finds the local network address from which this machine can connect to the target address. This method tries to establish a proper network connection to the given target, so it only succeeds if the target socket address actually accepts connections. The method tries various strategies multiple times and uses an exponential backoff timer between tries.

If no connection attempt was successful after the given maximum time, the method will choose some address based on heuristics (excluding link-local and loopback addresses.)

This method will initially not log on info level (to not flood the log while the backoff time is still very low). It will start logging after a certain time has passes.

Parameters:

targetAddress - The address that the method tries to connect to.

maxWaitMillis - The maximum time that this method tries to connect, before falling back to the heuristics.

startLoggingAfter - The time after which the method will log on INFO level.

Throws:

IOException

getAvailablePort

public static int getAvailablePort()

Find a non-occupied port.

Returns:

A non-occupied port.