From 8fc847e5b632c5f311f7a4dfc55204c486283c58 Mon Sep 17 00:00:00 2001
From: Stephan Ewen <sewen@apache.org>
Date: Wed, 22 Apr 2015 14:48:22 +0200
Subject: [PATCH] [client] Work around limitations of JDK 1.6 in
 InetSocketAddress

---
 .../main/java/org/apache/flink/client/program/Client.java   | 6 +++++-
 1 file changed, 5 insertions(+), 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
index c61e814eb8747..e219a38d6b668 100644
--- 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());