[client] Work around limitations of JDK 1.6 in InetSocketAddress

VonRosenchild · Apr 22, 2015 · 8fc847e · 8fc847e
1 parent 2b8db40
commit 8fc847e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/Client.java b/flink-clients/src/main/java/org/apache/flink/client/program/Client.java
@@ -114,7 +114,11 @@ public Client(InetSocketAddress jobManagerAddress, Configuration config,
 
  if (jobManagerAddress.isUnresolved()) {
  // address is unresolved, resolve it
- String host = jobManagerAddress.getHostString();
+ String host = jobManagerAddress.getHostName();
+ if (host == null) {
+ throw new IllegalArgumentException("Host in jobManagerAddress is null");
+ }
+
  try {
  InetAddress address = InetAddress.getByName(host);
  this.jobManagerAddress = new InetSocketAddress(address, jobManagerAddress.getPort());